IClusterManager.GetConsumerGroupOffsetsAsync method

Retrieves the offsets for a specified consumer group and a collection of topics. The offsets indicate where the consumer group is in its consumption of the topics.

public Task<IEnumerable<TopicPartitionOffset>> GetConsumerGroupOffsetsAsync(string consumerGroup, 
    IEnumerable<string> topicsName)

parameter	description
consumerGroup	The name of the consumer group for which to retrieve offsets.
topicsName	A collection of topic names for which to retrieve offsets.

Return Value

An enumerable collection of TopicPartitionOffset objects, each of which contains offset information for a specific topic partition in the consumer group.

See Also

• interface IClusterManager
• namespace KafkaFlow.Clusters