IMessageConsumer.Pause method

Pause consumption for the provided list of partitions.

public void Pause(IReadOnlyCollection<TopicPartition> partitions)

parameter	description
partitions	The partitions to pause consumption of.

Exceptions

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

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers