diff --git a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/receiver/kafka/BasicMessageContentReader.java b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/receiver/kafka/BasicMessageContentReader.java index d1a28a300e..3a1a3086f0 100644 --- a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/receiver/kafka/BasicMessageContentReader.java +++ b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/receiver/kafka/BasicMessageContentReader.java @@ -56,7 +56,7 @@ private void ensureExistence(Integer schemaVersion, Integer schemaId) { throw new RetryableReceiverError( String.format( "Requested schema not present yet for topic: %s, schemaVersion: %s, schemaId: %s", - topic, schemaVersion, schemaId), + topic.getQualifiedName(), schemaVersion, schemaId), ex); } }