Class KafkaClientProvider
- java.lang.Object
-
- org.apache.sling.distribution.journal.kafka.KafkaClientProvider
-
- All Implemented Interfaces:
Closeable,AutoCloseable,org.apache.sling.distribution.journal.MessagingProvider
public class KafkaClientProvider extends Object implements org.apache.sling.distribution.journal.MessagingProvider, Closeable
-
-
Field Summary
Fields Modifier and Type Field Description static intPARTITION
-
Constructor Summary
Constructors Constructor Description KafkaClientProvider(org.osgi.service.event.EventAdmin eventAdmin, KafkaEndpoint kafkaEndpoint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidassertTopic(String topic)StringassignTo(long offset)StringassignTo(org.apache.sling.distribution.journal.Reset reset, long relativeOffset)voidclose()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)CloseablecreatePoller(String topicName, org.apache.sling.distribution.journal.Reset reset, String assign, org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters)<T> org.apache.sling.distribution.journal.MessageSender<T>createSender(String topic)URIgetServerUri()longretrieveOffset(String topicName, org.apache.sling.distribution.journal.Reset reset)
-
-
-
Field Detail
-
PARTITION
public static final int PARTITION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
KafkaClientProvider
public KafkaClientProvider(org.osgi.service.event.EventAdmin eventAdmin, KafkaEndpoint kafkaEndpoint)
-
-
Method Detail
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
createSender
public <T> org.apache.sling.distribution.journal.MessageSender<T> createSender(String topic)
- Specified by:
createSenderin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
createPoller
public Closeable createPoller(String topicName, org.apache.sling.distribution.journal.Reset reset, @Nullable String assign, org.apache.sling.distribution.journal.HandlerAdapter<?>... adapters)
- Specified by:
createPollerin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assertTopic
public void assertTopic(String topic) throws org.apache.sling.distribution.journal.MessagingException
- Specified by:
assertTopicin interfaceorg.apache.sling.distribution.journal.MessagingProvider- Throws:
org.apache.sling.distribution.journal.MessagingException
-
retrieveOffset
public long retrieveOffset(String topicName, org.apache.sling.distribution.journal.Reset reset)
- Specified by:
retrieveOffsetin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assignTo
public String assignTo(long offset)
- Specified by:
assignToin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assignTo
public String assignTo(org.apache.sling.distribution.journal.Reset reset, long relativeOffset)
- Specified by:
assignToin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
createConsumer
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)
-
getServerUri
public URI getServerUri()
- Specified by:
getServerUriin interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
-