in library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializer.java [68:82]
private static Object convert(Class<?> type, Exchange exchange, Object value) {
if (value == null) {
return null;
}
if (value instanceof String) {
return value;
}
if (value instanceof byte[]) {
return new String((byte[]) value, StandardCharsets.UTF_8);
}
return value.toString();
}