From 947e1baf71922bfa9e3020589cbdd3d5018d8cfa Mon Sep 17 00:00:00 2001 From: Piotr Pauksztelo Date: Thu, 21 Nov 2024 12:35:24 +0100 Subject: [PATCH] Fix error message in kafka input --- logprep/connector/confluent_kafka/input.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/logprep/connector/confluent_kafka/input.py b/logprep/connector/confluent_kafka/input.py index 18100bb5a..c3625bd99 100644 --- a/logprep/connector/confluent_kafka/input.py +++ b/logprep/connector/confluent_kafka/input.py @@ -316,7 +316,7 @@ def _error_callback(self, error: KafkaException) -> None: the error that occurred """ self.metrics.number_of_errors += 1 - logger.error(f"{self.describe()}: {error}", ()) + logger.error(f"{self.describe()}: {error}") def _stats_callback(self, stats: str) -> None: """Callback for statistics data. This callback is triggered by poll()