fixup! manager/kafka_client.py: reconnect on unexpected errors

diff --git a/python/knot_resolver/manager/kafka_client.py b/python/knot_resolver/manager/kafka_client.py
index 9522bb0eac2dec1caf4409abf362fbaa10ec8628..d8ab89463d81a258a93f38382fd0eecc9d39658f 100644 (file)
--- a/python/knot_resolver/manager/kafka_client.py
+++ b/python/knot_resolver/manager/kafka_client.py
@@ -298,8 +298,10 @@ if KAFKA_LIB:
                 try:
                     logger.info("Started consuming messages...")
                     messages: Dict[TopicPartition, List[ConsumerRecord]] = self._consumer.poll(timeout_ms=100)
+                    logger.debug(f"Successfully consumed messages: {messages}")
                 except KafkaError as e:
                     logger.error(f"{error_msg_prefix} Kafka error:\n{e}")
+                    self._consumer_connect()
                 except Exception as e:
                     logger.error(f"{error_msg_prefix} unknown error:\n{e}")
                     self._consumer_connect()