Skip to content

Commit

Permalink
Merge pull request #825 from Aiven-Open/matyaskuti/log_message_error_…
Browse files Browse the repository at this point in the history
…in_schemareader

Log message error on schema replay
  • Loading branch information
keejon authored Feb 28, 2024
2 parents 0af2b7e + 8cc2027 commit 8de11f4
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions karapace/schema_reader.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 8de11f4

Please sign in to comment.