Interface IKafkaPartitionEofCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

Declares the OnEndOfTopicPartitionReached(TopicPartition, IKafkaConsumer) event handler.

public interface IKafkaPartitionEofCallback : IBrokerClientCallback

Remarks

The EnablePartitionEof must be set to true in the KafkaConsumerConfiguration, otherwise the underlying library will not emit this event.

Methods

OnEndOfTopicPartitionReached(TopicPartition, IKafkaConsumer)

Called to report that the end of a partition has been reached, meaning that it has been completely consumed.

void OnEndOfTopicPartitionReached(TopicPartition topicPartition, IKafkaConsumer consumer)

Parameters

topicPartition TopicPartition

The topic partition.

consumer IKafkaConsumer

The related consumer.

Remarks

The EnablePartitionEof must be set to true in the KafkaConsumerConfiguration, otherwise the underlying library will not emit this event.