I am using Confluent kafka C# client. how to get the latest offset consumed from a topic in this?
I am using Confluent kafka C# client. how to get the latest offset consumed from a topic in this?
You can use the Position() method from the consumer
like:
var partition = 0;
Offset lastOffset = _kafkaConsumer.Position(new TopicPartition("topic", partition));