Package io.eventuate.messaging.kafka.basic.consumer
package io.eventuate.messaging.kafka.basic.consumer
-
ClassDescriptionA Kafka consumer that manually commits offsets and supports asynchronous message processingProcesses a Kafka message and tracks the message offsets that have been successfully processed and can be committedKeeps track of message offsets that are (a) being processed and (b) have been processed and can be committedTracks the offsets for a TopicPartition that are being processed or have been processed