Interface IKafkaPartitionEofCallback
Declares the OnEndOfTopicPartitionReached(TopicPartition, KafkaConsumer) event handler.
Namespace: Silverback.Messaging.Broker.Callbacks
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaPartitionEofCallback : IBrokerCallbackRemarks
The EnablePartitionEof must be set to true in the
KafkaConsumerConfig, otherwise the underlying library will not emit this event.
Methods
| Improve this doc View sourceOnEndOfTopicPartitionReached(TopicPartition, KafkaConsumer)
Called to report that the end of a partition has been reached, meaning that it has been completely consumed.
Declaration
void OnEndOfTopicPartitionReached(TopicPartition topicPartition, KafkaConsumer consumer)Parameters
| Type | Name | Description |
|---|---|---|
| TopicPartition | topicPartition | The topic partition. |
| KafkaConsumer | consumer | The related consumer. |
Remarks
The EnablePartitionEof must be set to true in the
KafkaConsumerConfig, otherwise the underlying library will not emit this event.