public class DefaultKafkaConsumer<T> extends Object implements EventConsumer
Modifier and Type | Class and Description |
---|---|
static class |
DefaultKafkaConsumer.PolledTopic |
Constructor and Description |
---|
DefaultKafkaConsumer(EnvConfig config) |
Modifier and Type | Method and Description |
---|---|
protected void |
askAndProcessSnapshotOnDemand() |
protected void |
assign() |
protected void |
assignAndStartConsume() |
protected void |
assignAsALeader() |
protected void |
assignConsumer(org.apache.kafka.clients.consumer.Consumer<String,T> kafkaConsumer,
String topic) |
protected void |
assignReplica() |
protected void |
consume() |
protected void |
consumeControlFromBufferAsAReplica() |
protected void |
consumeEventsFromBufferAsALeader() |
protected void |
consumeEventsFromBufferAsAReplica() |
protected void |
defaultProcessAsAReplica() |
protected void |
defaultProcessAsLeader() |
protected void |
enableConsumeAndStartLoop(State state) |
protected void |
handleSnapshotBetweenIteration(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record) |
void |
initConsumer(ConsumerHandler consumerHandler) |
void |
poll() |
protected void |
pollControl() |
protected void |
pollEvents() |
protected void |
processControlAsAReplica(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record) |
protected void |
processEventsAsAReplica(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record) |
protected void |
processLeader(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record) |
protected void |
restart(State state) |
protected void |
restartConsumer() |
protected void |
saveOffset(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record,
org.apache.kafka.clients.consumer.Consumer<String,T> kafkaConsumer) |
protected void |
setLastProcessedKey() |
protected void |
settingsOnAEmptyControlTopic(ControlMessage lastWrapper) |
protected void |
startConsume() |
void |
stop() |
protected void |
stopConsume() |
protected void |
updateOnRunningConsumer(State state) |
void |
updateStatus(State state) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get
public DefaultKafkaConsumer(EnvConfig config)
public void initConsumer(ConsumerHandler consumerHandler)
initConsumer
in interface EventConsumer
protected void restartConsumer()
public void stop()
stop
in interface EventConsumer
public void updateStatus(State state)
updateStatus
in interface LeadershipCallback
protected void askAndProcessSnapshotOnDemand()
protected void assign()
protected void assignAsALeader()
protected void assignReplica()
protected void assignConsumer(org.apache.kafka.clients.consumer.Consumer<String,T> kafkaConsumer, String topic)
public void poll()
poll
in interface EventConsumer
protected void updateOnRunningConsumer(State state)
protected void restart(State state)
protected void enableConsumeAndStartLoop(State state)
protected void setLastProcessedKey()
protected void settingsOnAEmptyControlTopic(ControlMessage lastWrapper)
protected void assignAndStartConsume()
protected void consume()
protected void defaultProcessAsLeader()
protected void processLeader(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void consumeEventsFromBufferAsALeader()
protected void handleSnapshotBetweenIteration(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void defaultProcessAsAReplica()
protected void consumeEventsFromBufferAsAReplica()
protected void consumeControlFromBufferAsAReplica()
protected void processEventsAsAReplica(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void processControlAsAReplica(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void saveOffset(org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record, org.apache.kafka.clients.consumer.Consumer<String,T> kafkaConsumer)
protected void startConsume()
protected void stopConsume()
protected void pollControl()
protected void pollEvents()
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.