Пытаюсь работать с Kafka. В качестве клиента использую Confluent Kafka.
В настройках консьюмера стоит
"enable.auto.commit" "false"
"auto.offset.reset", "largest"
Ну и "group.id" задано. Коммит прочитанного сообщения осуществляется вручную вот этим методом: Consumer.CommitAsync(ICollection<TopicPartitionOffset> offsets).

Так вот, когда я перезапускаю консьюмер, он начинает считывать сообщения с последнего прочитанного сообщения. Т.е. он его читает два раза. А мне надо, чтобы консьюмер начинал читать со следующего за последним прочитанным сообщением. Может кто подсказать, как это сделать?