IMessageConsumer.GetTopicPartitionsLag method

Gets the lag of each topic/partitions assigned

public IEnumerable<TopicPartitionLag> GetTopicPartitionsLag()

Return Value

The list of topic, partition and lag

See Also

• class TopicPartitionLag
• interface IMessageConsumer
• namespace KafkaFlow.Consumers