TypeError: 'NoneType' object is not iterable

[avloss]

kafka-python/kafka/producer/kafka.py

Line 711 in bd557da

all_partitions = sorted(self._metadata.partitions_for_topic(topic))

Intermittently getting this issue - not sure what is going on - I'm intending for topics to be auto-created. So obviously they don't have partitions. Though it still manages to work overall somehow. Perhaps if I'm pushing one message, and the topic is being created, and doesn't yet have any partitions, then pushing second message to the same topic would produce this error. Very strange error, and I'm getting it a lot!

[jeffwidman]

Can you include example code and the full traceback? I realize the code works 99% of the time, and only intermittently throws the error and only with a new auto-created topic, but it'd still be helpful for stepping through what's happening.

[OlehDziuba]

Hi, have you found any solution for this?

[dpkp]

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