in src/main/java/org/apache/sling/distribution/journal/kafka/JsonRecordHandler.java [37:41]
public JsonRecordHandler(MessageHandler<T> handler, ObjectReader reader) {
this.reader = reader;
this.handler = requireNonNull(handler);
}