JavaScript is disabled on your browser.
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2007–2019
The Apache Software Foundation
. All rights reserved.