Matthew Seal

I was hoping given time Numpy would solve this for Python 3.12, but it seems they're just not going to so we likely need to add a limit for now:...

Thanks for reporting this with lots of details. Apologies no one responded earlier. There's some related segfaults around poll and closing: https://github.com/confluentinc/confluent-kafka-python/issues/457 https://github.com/confluentinc/confluent-kafka-python/issues/1761 I'm marking this higher priority to get...

Closing as further info was not provided

Closing the issue, but also giving some guidance for anyone who land here in the future. In general Kafka is a streaming system so it's oriented around fast and reliable...

The library should handle `partition count changed from 1 to 0` more gracefully. That being said I'm not sure what the expected behavior is from a topic deletion and recreation...

Yes it's confusing because flush pushes into the internal queue but doesn't guarantee that the message is sent out. I've proposed we add a flag to flush to enable it...

Some sort of strip metadata option would make sense so it could be controlled. Happy to review a PR that adds this though I'm not available for a while to...

Closing as no new information on trying new kafka version was provided

I agree it should be more flexible here to input arguments or error on invalid argument types in a way that's clearer how to resolve.

https://github.com/confluentinc/confluent-kafka-python/issues/977 is also getting in the way to just pass the cert in memory I believe. Can you copy the file to another location rather than symlink in gcp?