Skip to content

Make the behaviour consistent when polling kafka

Currently, when polling Kafka there is a different behaviour when using kafka-python vs python-confluent-kafka if there is no topic to consume. When using python-kafka an empty dictionary is returned, however, using python-confluent-kafka returns a non-empty dictionary containing {'all_messages':[]}. This has been changed so both cases return an empty dictionary.

Edited by Rhys Poulton

Merge request reports

Loading