IMessageConsumer.GetPosition method

Gets the current position (offset) for the specified topic / partition. The offset field of each requested partition will be set to the offset of the last consumed message + 1, or Offset.Unset in case there was no previous message consumed by this consumer.

public Offset GetPosition(TopicPartition topicPartition)

Exceptions

exception	condition
KafkaException	Thrown if the request failed.

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers