A C G H J K O P R S T
All Classes All Packages
All Classes All Packages
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
All Classes All Packages