Interface IKafkaPartitionsRevokedCallback
Declares the OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset>, IKafkaConsumer) event handler.
Namespace: Silverback.Messaging.Broker.Callbacks
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaPartitionsRevokedCallback : IBrokerClientCallbackMethods
OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset>, IKafkaConsumer)
Called immediately prior to a group partition assignment being revoked.
Declaration
void OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset> topicPartitionsOffset, IKafkaConsumer consumer)Parameters
| Type | Name | Description |
|---|---|---|
| IReadOnlyCollection<TopicPartitionOffset> | topicPartitionsOffset | A collection of Confluent.Kafka.TopicPartitionOffset representing the set of partitions the consumer is currently assigned to, and the current position of the consumer on each of these partitions. |
| IKafkaConsumer | consumer | The related consumer instance. |