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
..
confluent_kafka	Catch the case when no new messages are available	2019-03-20 12:48:46 +01:00
expression_parser	Add alarm expression parser	2018-04-12 13:38:30 +02:00
healthcheck	Invalid kafka check script name	2016-04-05 06:17:46 +02:00
kafka	Ensures that messages pass to kafka client are bytes string	2018-07-31 12:09:01 +02:00
kafka_lib	Updated pep8 checks	2018-04-04 14:39:41 +00:00
monasca_query_language	Updated pep8 checks	2018-04-04 14:39:41 +00:00
policy	Update the outdated URL	2018-09-23 16:41:40 +08:00
repositories	Updated pep8 checks	2018-04-04 14:39:41 +00:00
rest	Make monasca-common pep8 compatible	2016-06-04 09:22:43 +00:00
simport	TrivialFix: Remove logging import unused	2016-09-23 17:07:11 +07:00
tests	Merge "Add wrapper for Confluent Kafka client consumer"	2019-02-28 22:18:01 +00:00
validation	Add the metric name to the Exception message when validation fails	2019-02-28 10:37:10 +00:00
__init__.py	Remove unnecessary executable permissions	2016-05-24 09:28:30 +02:00