Dana Powers comments

Results 48 comments of


                                            Dana Powers

TypeError: 'NoneType' object is not iterable

This is probably caused by a race condition caused by a new metadata response between `_wait_for_metadata` and `_partition`.

kafka-python should package test module / fixtures

Can you elaborate? which testing facilities do you mean?

kafka-python should package test module / fixtures

Ok -- fixture code requires getting and managing all the data in the `servers/` directory. How would you envision managing that as an exported package?

KafkaConsumer.subscribe(topics='t', pattern='^t') should throw ValueError not AssertionError

makes sense and on board! I am a fan of asserts to document assumptions, but I think you're right that we're probably abusing them in cases like this.

KafkaConsumer.subscribe(topics='t', pattern='^t') should throw ValueError not AssertionError

Also note that technically what is raised is `IllegalStateError` which isn't strictly an assertion. This was done to mirror the java client, which I believe raises a similar error in...

Improve Exception handling for NoBrokersAvailable / missing api_version parameter

> I think it would be great if there would me a more meaningful exception (like UnsupportedApiVersion) that is indicating to the user that the api version that he is...

Consumer proceeds on when ConsumerRebalanceListener fails

Agree that this seems strange. We're following the java client design very closely on this, and it follows the same pattern -- Exceptions are caught and logged. One alternate approach...

Consumer proceeds on when ConsumerRebalanceListener fails

Related: #2143

`bootstrap_connected` is returning false even though connection is still there

This is expected. The "bootstrap" connections are exactly that: bootstraps. They are disconnected once the normal cluster connections are established. You can see this in the logs you posted. node_id=1...

Advice needed. How to connect to Kafka with Private Key Certificate

kafka-python passes config directly to python's ssl module (load_cert_chain). If you need assistance, perhaps consult python ssl docs more generally.