Class JsonRecordHandler<T>
- java.lang.Object
-
- org.apache.sling.distribution.journal.kafka.JsonRecordHandler<T>
-
public class JsonRecordHandler<T> extends Object
-
-
Constructor Summary
Constructors Constructor Description JsonRecordHandler(org.apache.sling.distribution.journal.MessageHandler<T> handler, com.fasterxml.jackson.databind.ObjectReader reader)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)
-
-
-
Field Detail
-
handler
public final org.apache.sling.distribution.journal.MessageHandler<T> handler
-
reader
public final com.fasterxml.jackson.databind.ObjectReader reader
-
-
Constructor Detail
-
JsonRecordHandler
public JsonRecordHandler(org.apache.sling.distribution.journal.MessageHandler<T> handler, com.fasterxml.jackson.databind.ObjectReader reader)
-
-
Method Detail
-
accept
public void accept(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record) throws IOException
- Throws:
IOException
-
-