From 459b34cfaf710163a360641bbb8732af0c1ab643 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 4 Dec 2019 14:44:01 -0500 Subject: [PATCH] Fix exception message in HeaderEnricher --- .../java/org/springframework/kafka/streams/HeaderEnricher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)); });