diff --git a/monasca_common/confluent_kafka/consumer.py b/monasca_common/confluent_kafka/consumer.py index de645635..334a47e4 100644 --- a/monasca_common/confluent_kafka/consumer.py +++ b/monasca_common/confluent_kafka/consumer.py @@ -70,6 +70,10 @@ class KafkaConsumer(object): continue elif not message.error(): yield message + elif message.error().code() == \ + confluent_kafka.KafkaError._PARTITION_EOF: + time.sleep(0.1) + continue else: log.error("Kafka error: %s", message.error().str()) raise confluent_kafka.KafkaException(message.error())