confluentinc / confluentinc/confluent-kafka-python
Segfault if poll() called from delivery_callback
- 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.