confluent-kafka-python
confluent-kafka-python copied to clipboard
Initializing producer throws segfault
Description
Confluent-kafka-python will exit with an error when running in the twisted framework.
I found that using version 1.9.2 can run in the twisted framework, but versions after 2.0.2 will throw an exception.
The stack information is as follows:
Can you help me find the cause and suggest a fix?
How to reproduce
from confluent_kafka import Producer
from twisted.internet import reactor
from twisted.internet.threads import deferToThread
def instantiate_producer():
producer_config = {
'bootstrap.servers': ['127.0.0.1:9092'],
}
Producer(producer_config)
def handle_result(*args):
reactor.stop()
d = deferToThread(instantiate_producer)
d.addCallback(handle_result)
reactor.run()
Dependent environment is as follows: os Centos7.6 Python 3.7.4 Twisted 19.7.0 confluent-kafka 2.3.0 Kafka 2.4.1
Checklist
Please provide the following information:
- [ ] confluent-kafka-python and librdkafka version (
confluent_kafka.version()andconfluent_kafka.libversion()): - [ ] Apache Kafka broker version:
- [ ] Client configuration:
{...} - [ ] Operating system: Centos7.6
- [ ] Provide client logs (with
'debug': '..'as necessary) - [ ] Provide broker log excerpts
- [ ] Critical issue