Fix exception message in HeaderEnricher

garyrussell · garyrussell · commit 459b34cfaf71 · 2019-12-04T14:44:01.000-05:00
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
@@ -63,7 +63,7 @@ public KeyValue<K, V> transform(K key, V value) {
 				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));
 		});

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ public KeyValue<K, V> transform(K key, V value) {`
`63`	`63`	`headerValue = ((String) headerValue).getBytes(StandardCharsets.UTF_8);`
`64`	`64`	`}`
`65`	`65`	`else if (!(headerValue instanceof byte[])) {`
`66`		`- throw new IllegalStateException("Invalid header value type" + headerValue.getClass());`
	`66`	`+ throw new IllegalStateException("Invalid header value type: " + headerValue.getClass());`
`67`	`67`	`}`
`68`	`68`	`headers.add(new RecordHeader(name, (byte[]) headerValue));`
`69`	`69`	`});`