public class DefaultKafkaConsumer<T> extends Object implements EventConsumer
Modifier and Type | Class and Description |
---|---|
static class |
DefaultKafkaConsumer.PolledTopic |
Modifier and Type | Field and Description |
---|---|
static String |
PRIMARY_CONSUMER |
static String |
SECONDARY_CONSUMER |
Constructor and Description |
---|
DefaultKafkaConsumer(EnvConfig config,
Producer producer) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
askAndProcessSnapshotOnDemand(SnapshotInfos snapshotInfos) |
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) |
public static final String SECONDARY_CONSUMER
public static final String PRIMARY_CONSUMER
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 boolean askAndProcessSnapshotOnDemand(SnapshotInfos snapshotInfos)
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.