Interface IKafkaPartitionsRevokedCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

Declares the OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset>, IKafkaConsumer) event handler.

public interface IKafkaPartitionsRevokedCallback : IBrokerClientCallback

Methods

OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset>, IKafkaConsumer)

Called immediately prior to a group partition assignment being revoked.

void OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset> topicPartitionsOffset, IKafkaConsumer consumer)

Parameters

topicPartitionsOffset IReadOnlyCollection<TopicPartitionOffset>

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.

consumer IKafkaConsumer

The related consumer instance.