in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java [77:80]
<T> JsonRecordHandler<T> toHandler(HandlerAdapter<T> adapter) {
ObjectReader reader = mapper.readerFor(adapter.getType());
return new JsonRecordHandler<>(adapter.getHandler(), reader);
}