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 int
PARTITION
-
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 void
assertTopic(String topic)
String
assignTo(long offset)
String
assignTo(org.apache.sling.distribution.journal.Reset reset, long relativeOffset)
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)
Closeable
createPoller(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)
URI
getServerUri()
long
retrieveOffset(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:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
createSender
public <T> org.apache.sling.distribution.journal.MessageSender<T> createSender(String topic)
- Specified by:
createSender
in 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:
createPoller
in interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assertTopic
public void assertTopic(String topic) throws org.apache.sling.distribution.journal.MessagingException
- Specified by:
assertTopic
in 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:
retrieveOffset
in interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assignTo
public String assignTo(long offset)
- Specified by:
assignTo
in interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
assignTo
public String assignTo(org.apache.sling.distribution.journal.Reset reset, long relativeOffset)
- Specified by:
assignTo
in 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:
getServerUri
in interfaceorg.apache.sling.distribution.journal.MessagingProvider
-
-