A C G H J K O P R S T 
All Classes All Packages

A

accept(ConsumerRecord<String, String>) - Method in class org.apache.sling.distribution.journal.kafka.JsonRecordHandler
 
assertTopic(String) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
assignTo(long) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
assignTo(Reset, long) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 

C

close() - Method in class org.apache.sling.distribution.journal.kafka.CLSwitch
 
close() - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
close() - Method in class org.apache.sling.distribution.journal.kafka.KafkaPoller
 
CLSwitch - Class in org.apache.sling.distribution.journal.kafka
 
CLSwitch(ClassLoader) - Constructor for class org.apache.sling.distribution.journal.kafka.CLSwitch
 
createConsumer(Class<? extends Deserializer<?>>, Reset) - 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(String) - 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
 
getProps() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
getServerUri() - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
getTopic() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 

H

handle(ConsumerRecord<String, String>) - Method in class org.apache.sling.distribution.journal.kafka.KafkaPoller
 
handler - Variable in class org.apache.sling.distribution.journal.kafka.JsonRecordHandler
 

J

JsonRecordHandler<T> - Class in org.apache.sling.distribution.journal.kafka
 
JsonRecordHandler(MessageHandler<T>, ObjectReader) - Constructor for class org.apache.sling.distribution.journal.kafka.JsonRecordHandler
 

K

kafkaBootstrapServers() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
KafkaClientProvider - Class in org.apache.sling.distribution.journal.kafka
 
KafkaClientProvider(EventAdmin, KafkaEndpoint) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
kafkaDefaultApiTimeout() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
KafkaEndpoint - Annotation Type in org.apache.sling.distribution.journal.kafka
 
KafkaJsonMessageSender<T> - Class in org.apache.sling.distribution.journal.kafka
 
KafkaJsonMessageSender(KafkaProducer<String, String>, String, ExceptionEventSender) - 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
 
KafkaMessageInfo(ConsumerRecord<String, ?>, Map<String, String>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
KafkaPoller - Class in org.apache.sling.distribution.journal.kafka
 
KafkaPoller(KafkaConsumer<String, String>, ExceptionEventSender, List<HandlerAdapter<?>>) - Constructor for class org.apache.sling.distribution.journal.kafka.KafkaPoller
 
kafkaRequestTimeout() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
KEY_MESSAGE_TYPE - Static variable in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 

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

reader - Variable in class org.apache.sling.distribution.journal.kafka.JsonRecordHandler
 
retrieveOffset(String, Reset) - Method in class org.apache.sling.distribution.journal.kafka.KafkaClientProvider
 
run() - Method in class org.apache.sling.distribution.journal.kafka.KafkaPoller
 

S

saslJaasConfig() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
saslMechanism() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
securityProtocol() - Method in annotation type org.apache.sling.distribution.journal.kafka.KafkaEndpoint
 
send(T) - Method in class org.apache.sling.distribution.journal.kafka.KafkaJsonMessageSender
 
send(T, Map<String, String>) - Method in class org.apache.sling.distribution.journal.kafka.KafkaJsonMessageSender

T

toString() - Method in class org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
 
A C G H J K O P R S T 
All Classes All Packages