Skip to content

Commit

Permalink
Fix error message in kafka input
Browse files Browse the repository at this point in the history
  • Loading branch information
ppcad committed Nov 21, 2024
1 parent df1af96 commit 947e1ba
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion logprep/connector/confluent_kafka/input.py
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit 947e1ba

Please sign in to comment.