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