confluentinc / confluentinc/confluent-kafka-python

Segfault if poll() called from delivery_callback

Open
#457 4 comments 1 reaction 0 assignees View on GitHub
bug enhancement investigate further status:waiting-for-interest
Dominant language
Python
Stars
509
Forks
964
Avg merge
2d 2h
Merged PRs (30d)
14

Description

Description
===========

Calling poll() from the delivery_callback results in a segfault. It should raise an exception instead.

How to reproduce
================

```
from confluent_kafka import Producer

p = Producer({'bootstrap.servers': ...})

def delivery_callback(err, msg):
p.poll(0)

for d in range(5):
p.produce('test', str(d), callback=delivery_callback)

p.flush()
```

Checklist
=========
Please provide the following information:

- [x] confluent-kafka-python and librdkafka version (`confluent_kafka.version()` and `confluent_kafka.libversion()`): `('0.11.5', 722176), ('0.11.5', 722431)`
- [x] Apache Kafka broker version: 2.11-1.1.0
- [ ] Client configuration: `{...}`
- [x] Operating system: linux
- [ ] Provide client logs (with `'debug': '..'` as necessary)
- [ ] Provide broker log excerpts
- [ ] Critical issue

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.