Package io.eventuate.messaging.kafka.basic.consumer

Class EventuateKafkaConsumer

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumer

public class EventuateKafkaConsumer
extends Object

A Kafka consumer that manually commits offsets and supports asynchronous message processing

Constructor Summary

Constructors

Constructor	Description
EventuateKafkaConsumer(String subscriberId, EventuateKafkaConsumerMessageHandler handler, List<String> topics, String bootstrapServers, EventuateKafkaConsumerConfigurationProperties eventuateKafkaConsumerConfigurationProperties, KafkaConsumerFactory kafkaConsumerFactory)

Method Summary

Modifier and Type	Method	Description
EventuateKafkaConsumerState	getState()
boolean	isCloseConsumerOnStop()
void	setCloseConsumerOnStop(boolean closeConsumerOnStop)
void	setConsumerCallbacks(Optional<ConsumerCallbacks> consumerCallbacks)
void	start()
void	stop()
static List<org.apache.kafka.common.PartitionInfo>	verifyTopicExistsBeforeSubscribing(KafkaMessageConsumer consumer, String topic)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventuateKafkaConsumer

public EventuateKafkaConsumer(String subscriberId,
 EventuateKafkaConsumerMessageHandler handler,
 List<String> topics,
 String bootstrapServers,
 EventuateKafkaConsumerConfigurationProperties eventuateKafkaConsumerConfigurationProperties,
 KafkaConsumerFactory kafkaConsumerFactory)

Method Details

setConsumerCallbacks

public void setConsumerCallbacks(Optional<ConsumerCallbacks> consumerCallbacks)

isCloseConsumerOnStop

public boolean isCloseConsumerOnStop()

setCloseConsumerOnStop

public void setCloseConsumerOnStop(boolean closeConsumerOnStop)

verifyTopicExistsBeforeSubscribing

public static List<org.apache.kafka.common.PartitionInfo> verifyTopicExistsBeforeSubscribing(KafkaMessageConsumer consumer,
 String topic)

start

public void start()

stop

public void stop()

getState

public EventuateKafkaConsumerState getState()