Interface IKafkaPartitionEofCallback

Declares the OnEndOfTopicPartitionReached(TopicPartition, IKafkaConsumer) event handler.

Namespace: Silverback.Messaging.Broker.Callbacks

Assembly: Silverback.Integration.Kafka.dll

Syntax

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.

Declaration

void OnEndOfTopicPartitionReached(TopicPartition topicPartition, IKafkaConsumer consumer)

Parameters

Type	Name	Description
TopicPartition	topicPartition	The topic partition.
IKafkaConsumer	consumer	The related consumer.

Remarks

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