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: