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