diff --git a/spring-kafka/src/main/java/org/springframework/kafka/streams/HeaderEnricher.java b/spring-kafka/src/main/java/org/springframework/kafka/streams/HeaderEnricher.java index 6c520be8..aabcb7f6 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/streams/HeaderEnricher.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/streams/HeaderEnricher.java @@ -63,7 +63,7 @@ public class HeaderEnricher implements Transformer> { headerValue = ((String) headerValue).getBytes(StandardCharsets.UTF_8); } else if (!(headerValue instanceof byte[])) { - throw new IllegalStateException("Invalid header value type" + headerValue.getClass()); + throw new IllegalStateException("Invalid header value type: " + headerValue.getClass()); } headers.add(new RecordHeader(name, (byte[]) headerValue)); });