Skip navigation links
A C G K O P R S T 

A

activate(KafkaEndpoint) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
assertTopic(String) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
assignTo(long) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 

C

close() - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
close() - Method in class org.apache.sling.distribution.journal.kafka.KafkaJsonMessagePoller
 
close() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessagePoller
 
createConsumer(Class<? extends Deserializer<?>>, Reset) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
createJsonPoller(String, Reset, MessageHandler<T>, Class<T>) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
createJsonSender() - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
createPoller(String, Reset, HandlerAdapter<?>...) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
createPoller(String, Reset, String, HandlerAdapter<?>...) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
createSender() - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 

G

getCreateTime() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
getOffset() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
getPartition() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
getTopic() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 

K

KafkaClientProvider - Class in org.apache.sling.distribution.journal.kafka
 
KafkaClientProvider() - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
KafkaEndpoint - Annotation Type in org.apache.sling.distribution.journal.kafka
 
KafkaJsonMessagePoller<T> - Class in org.apache.sling.distribution.journal.kafka
 
KafkaJsonMessagePoller(KafkaConsumer<String, String>, MessageHandler<T>, Class<T>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaJsonMessagePoller
 
KafkaJsonMessageSender<T> - Class in org.apache.sling.distribution.journal.kafka
 
KafkaJsonMessageSender(KafkaProducer<String, String>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaJsonMessageSender
 
KafkaMessageInfo - Class in org.apache.sling.distribution.journal.kafka
 
KafkaMessageInfo(ConsumerRecord<String, ?>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
KafkaMessagePoller - Class in org.apache.sling.distribution.journal.kafka
 
KafkaMessagePoller(KafkaConsumer<String, byte[]>, HandlerAdapter<?>...) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaMessagePoller
 
KafkaMessageSender<T extends com.google.protobuf.GeneratedMessage> - Class in org.apache.sling.distribution.journal.kafka
 
KafkaMessageSender(KafkaProducer<String, byte[]>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaMessageSender
 

O

org.apache.sling.distribution.journal.kafka - package org.apache.sling.distribution.journal.kafka
 

P

PARTITION - Static variable in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 

R

retrieveOffset(String, Reset) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
run() - Method in class org.apache.sling.distribution.journal.kafka.KafkaJsonMessagePoller
 
run() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessagePoller
 

S

send(String, T) - Method in class org.apache.sling.distribution.journal.kafka.KafkaJsonMessageSender
send(String, T) - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageSender

T

toString() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
A C G K O P R S T 
Skip navigation links

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.