confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Initializing producer throws segfault

Open asas1235066 opened this issue 1 year ago • 0 comments

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: 17129008166569

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() and confluent_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

asas1235066 avatar Apr 12 '24 05:04 asas1235066