Description
Since confluent-kafka 2.1.0, subscribing to a non-existent topic causes python to segfault.
How to reproduce
Using the files in this gist, run docker compose, then run script test.py
- at first, with no modifications
- then, with the admin client part commented out: in short, don't create the topic
The first run will be successful. The second run will log Segmentation fault (core dumped)
With confluent-kafka 2.0.2, poll returns a message with value b'Subscribed topic not available: test-cf67de5e-e79e-48f7-9300-763fb5b8bc05: Broker: Unknown topic or partition'
Checklist
Please provide the following information:
Description
Since confluent-kafka 2.1.0, subscribing to a non-existent topic causes python to segfault.
How to reproduce
Using the files in this gist, run docker compose, then run script
test.pyThe first run will be successful. The second run will log
Segmentation fault (core dumped)With confluent-kafka 2.0.2,
pollreturns a message with valueb'Subscribed topic not available: test-cf67de5e-e79e-48f7-9300-763fb5b8bc05: Broker: Unknown topic or partition'Checklist
Please provide the following information:
confluent_kafka.version()andconfluent_kafka.libversion()): ('2.1.0', 33619968) ('2.1.0', 33620223){...}: in the gist'debug': '..'as necessary)