IConsumer.OnPartitionsRevoked method
Register a handler to be executed when the partitions are revoked
public void OnPartitionsRevoked(
Action<IDependencyResolver, IConsumer<byte[], byte[]>, List<TopicPartitionOffset>> handler)
parameter | description |
---|---|
handler | The handler that will be executed |
See Also
- interface IConsumer
- namespace KafkaFlow.Consumers