Witek Bedyk 5bdd98662b Catch the case when no new messages are available ...

Confluent Kafka client throws the KafkaError._PARTITION_EOF exception
when no new messages are available in a given partitiion. We should
catch this case and continue consuming after a short sleep.

Story: 2003705
Task: 30116
Change-Id: I44add24df764bbc4e718358a8af75903e035f3f0

2019-03-20 12:48:46 +01:00

..

__init__.py

Add wrapper for Confluent Kafka async Producer

2018-11-28 09:56:34 +01:00

consumer.py

Catch the case when no new messages are available

2019-03-20 12:48:46 +01:00

producer.py

Add wrapper for Confluent Kafka async Producer

2018-11-28 09:56:34 +01:00