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

Class KafkaMessageProcessor

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.KafkaMessageProcessor

public class KafkaMessageProcessor
extends Object

Processes a Kafka message and tracks the message offsets that have been successfully processed and can be committed

Constructor Summary

Constructors

Constructor	Description
KafkaMessageProcessor(String subscriberId, EventuateKafkaConsumerMessageHandler handler)

Method Summary

Modifier and Type	Method	Description
int	backlog()
OffsetTracker	getPending()
void	noteOffsetsCommitted(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit)
Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>	offsetsToCommit()
void	process(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaMessageProcessor

public KafkaMessageProcessor(String subscriberId,
 EventuateKafkaConsumerMessageHandler handler)

Method Details

process

public void process(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

offsetsToCommit

public Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit()

noteOffsetsCommitted

public void noteOffsetsCommitted(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit)

getPending

public OffsetTracker getPending()

backlog

public int backlog()