IConsumer.OnPartitionsAssigned method

Register a handler to be executed when the partitions are assigned

public void OnPartitionsAssigned(
    Action<IDependencyResolver, IConsumer<byte[], byte[]>, List<TopicPartition>> handler)

parameter	description
handler	The handler that will be executed

See Also

• interface IConsumer
• namespace KafkaFlow.Consumers