я создал Кафки потребителя с помощью нового API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)Кафка обычай потребитель читать входящие записи
В настоящее время потребитель читает читает сообщения из темы, начиная от самого маленького смещения. Я хочу переопределить это для чтения из последнего смещения. Любые указания на то, как это можно сделать?
После того, как вы начнете читать сообщения для данной группы потребителей, вам нужно будет принудительно принудительно отключить пользователя до конца разделов, которые следуют с помощью метода seekToEnd(). Для групп потребителей, которые еще не прочитали никаких сообщений, вы можете использовать свойство auto.offset.reset = наибольшее, чтобы сообщить потребителю, где читать его первое сообщение.
Попробуйте установить auto.offset.reset = largest, хотя это должно быть значение по умолчанию.