From 8cc2027a904425800811fce935e6d1e4a27a0c30 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?M=C3=A1ty=C3=A1s=20Kuti?= <matyas.kuti@aiven.io>
Date: Wed, 28 Feb 2024 11:04:41 +0100
Subject: [PATCH] Log message error on schema replay

It's a valid scenario that a message with `error()` set is consumed,
however these are retriable in most cases, thus only logging for now.
---
 karapace/schema_reader.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/karapace/schema_reader.py b/karapace/schema_reader.py
index 283ffb659..f3d7dd5b9 100644
--- a/karapace/schema_reader.py
+++ b/karapace/schema_reader.py
@@ -317,6 +317,7 @@ def handle_messages(self) -> None:
             try:
                 message_key = msg.key()
                 if message_key is None:
+                    LOG.warning("Empty message key when consuming from topic %s, error: %s", msg.topic(), msg.error())
                     continue
                 key = json_decode(message_key)
             except JSONDecodeError: