Jeff Widman
Jeff Widman
A PR would be welcome...
A PR would be most welcome!
I don't think anyone has put together a PR, but if you did we'd be happy to review it.
I like this PR's goal of creating a stronger separation btween the "liveness" check from the "which version" check.
What's needed to push this across the line?
Are you using `KafkaClient` directly? In particular, this method: http://kafka-python.readthedocs.io/en/master/apidoc/KafkaClient.html#kafka.client.KafkaClient.check_version Do you have a copy of the stacktrace? Also, 2.12 is the Scala version, not the broker version. Do you...
This doesn't quite make sense to me... you say you're using `KafkaClient`, but then show code using `KafkaProducer`... Does your code ever directly call `KafkaClient.check_version()`?? Or is it just that...
Looking at this again, now that I know more of how the code works, what's failing here is the version probing upon initial bootstrapping. I'm very curious what the broker...
This has often been caused by a SSL/SASL issue... see https://github.com/dpkp/kafka-python/issues/1796
The idea makes sense, I haven't had time to look through the implementation, but I'm 👍 on the idea. The one thing I vaguely remember is there are consumer groups...