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