fixup! manager/kafka_client.py: support for binary files

diff --git a/python/knot_resolver/manager/kafka_client.py b/python/knot_resolver/manager/kafka_client.py
index 31cfd26b946c11fe56dc1b13f639cc40df84ddb5..e7dc4e27ea9346a5b1b630bd287a0fb838d4570e 100644 (file)
--- a/python/knot_resolver/manager/kafka_client.py
+++ b/python/knot_resolver/manager/kafka_client.py
@@ -301,7 +301,7 @@ 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}")
+                    logger.debug(f"Successfully consumed {len(messages)} messages")
                 except KafkaError as e:
                     logger.error(f"{error_msg_prefix} Kafka error:\n{e}")
                     self._consumer_connect()