]> git.ipfire.org Git - thirdparty/knot-resolver.git/commitdiff
fixup! manager/kafka_client.py: support for binary files
authorAleš Mrázek <ales.mrazek@nic.cz>
Fri, 10 Oct 2025 11:41:53 +0000 (13:41 +0200)
committerAleš Mrázek <ales.mrazek@nic.cz>
Mon, 27 Oct 2025 09:44:53 +0000 (10:44 +0100)
python/knot_resolver/manager/kafka_client.py

index 31cfd26b946c11fe56dc1b13f639cc40df84ddb5..e7dc4e27ea9346a5b1b630bd287a0fb838d4570e 100644 (file)
@@ -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()