Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix exception message in HeaderEnricher

Browse Source
This commit is contained in:
Gary Russell
2019-12-04 14:44:01 -05:00
parent d8e367799e
commit 459b34cfaf
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka/src/main/java/org/springframework/kafka/streams/HeaderEnricher.java
View File

@@ -63,7 +63,7 @@ public class HeaderEnricher<K, V> implements Transformer<K, V, KeyValue<K, V>> {
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));
});