From fa188feca3f8fe8449b5d1124247d82008d9d5d3 Mon Sep 17 00:00:00 2001 From: Braden Groom Date: Mon, 7 Aug 2023 14:39:35 -0500 Subject: [PATCH] Improve kafka logging (#803) --- baseplate/frameworks/queue_consumer/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/baseplate/frameworks/queue_consumer/kafka.py b/baseplate/frameworks/queue_consumer/kafka.py index 4ca709c3b..cf2f1d127 100644 --- a/baseplate/frameworks/queue_consumer/kafka.py +++ b/baseplate/frameworks/queue_consumer/kafka.py @@ -177,7 +177,7 @@ def handle(self, message: confluent_kafka.Message) -> None: data = self.message_unpack_fn(blob) except Exception: prom_success = "false" - logger.error("skipping invalid message") + logger.exception("skipping invalid message") context.span.incr_tag(f"{self.name}.{topic}.invalid_message") return