public class KafkaMessagePoller extends Object implements Closeable
Constructor and Description |
---|
KafkaMessagePoller(org.apache.kafka.clients.consumer.KafkaConsumer<String,byte[]> consumer,
org.apache.sling.distribution.journal.HandlerAdapter<?>... handlerAdapters) |
public KafkaMessagePoller(org.apache.kafka.clients.consumer.KafkaConsumer<String,byte[]> consumer, org.apache.sling.distribution.journal.HandlerAdapter<?>... handlerAdapters)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void run()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.