IMessageConsumer.Resume method

Resume consumption for the provided list of partitions.

public void Resume(IReadOnlyCollection<TopicPartition> partitions)

parameter	description
partitions	The partitions to resume consumption of.

Exceptions

exception	condition
KafkaException	Thrown if the request failed.
TopicPartitionException	Per partition success or error.

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers