JsonRecordHandler toHandler()

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);
    }