Improve kafka logging (#803)

reddit · Aug 7, 2023 · fa188fe · fa188fe
1 parent 549faab
commit fa188fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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