public class KafkaClientProvider extends Object implements org.apache.sling.distribution.journal.MessagingProvider, Closeable
Modifier and Type | Field and Description |
---|---|
static int |
PARTITION |
Constructor and Description |
---|
KafkaClientProvider() |
Modifier and Type | Method and Description |
---|---|
void |
activate(KafkaEndpoint kafkaEndpoint) |
void |
assertTopic(String topic) |
String |
assignTo(long offset) |
void |
close() |
protected <T> org.apache.kafka.clients.consumer.KafkaConsumer<String,T> |
createConsumer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> deserializer,
org.apache.sling.distribution.journal.Reset reset) |
<T> Closeable |
createJsonPoller(String topicName,
org.apache.sling.distribution.journal.Reset reset,
org.apache.sling.distribution.journal.MessageHandler<T> handler,
Class<T> type) |
<T> org.apache.sling.distribution.journal.JsonMessageSender<T> |
createJsonSender() |
<T> Closeable |
createPoller(String topicName,
org.apache.sling.distribution.journal.Reset reset,
org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters) |
Closeable |
createPoller(String topicName,
org.apache.sling.distribution.journal.Reset reset,
String assign,
org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters) |
<T extends com.google.protobuf.GeneratedMessage> |
createSender() |
long |
retrieveOffset(String topicName,
org.apache.sling.distribution.journal.Reset reset) |
public static final int PARTITION
public void activate(KafkaEndpoint kafkaEndpoint)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public <T extends com.google.protobuf.GeneratedMessage> org.apache.sling.distribution.journal.MessageSender<T> createSender()
createSender
in interface org.apache.sling.distribution.journal.MessagingProvider
public <T> Closeable createPoller(String topicName, org.apache.sling.distribution.journal.Reset reset, org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters)
createPoller
in interface org.apache.sling.distribution.journal.MessagingProvider
public Closeable createPoller(String topicName, org.apache.sling.distribution.journal.Reset reset, @Nullable String assign, org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters)
createPoller
in interface org.apache.sling.distribution.journal.MessagingProvider
public <T> org.apache.sling.distribution.journal.JsonMessageSender<T> createJsonSender()
createJsonSender
in interface org.apache.sling.distribution.journal.MessagingProvider
public <T> Closeable createJsonPoller(String topicName, org.apache.sling.distribution.journal.Reset reset, org.apache.sling.distribution.journal.MessageHandler<T> handler, Class<T> type)
createJsonPoller
in interface org.apache.sling.distribution.journal.MessagingProvider
public void assertTopic(String topic) throws org.apache.sling.distribution.journal.MessagingException
assertTopic
in interface org.apache.sling.distribution.journal.MessagingProvider
org.apache.sling.distribution.journal.MessagingException
public long retrieveOffset(String topicName, org.apache.sling.distribution.journal.Reset reset)
retrieveOffset
in interface org.apache.sling.distribution.journal.MessagingProvider
public String assignTo(long offset)
assignTo
in interface org.apache.sling.distribution.journal.MessagingProvider
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.