Как сделать так, чтобы GetKafka всегда читал с последнего смещения в Apache Nifi?

Question

Я использую GetKafka Apache Nifi для чтения сообщения.

Когда я перезагружаю процессор, я бы хотел, чтобы он всегда читал из последнего смещения, а не смещения, зафиксированного этой группой.

Как мне этого добиться?

Answer 1

Процессор GetKafka устарел . Пожалуйста, используйте вместо этого ConsumeKafka процессор. Этот процессор имеет настройку под названием Сброс смещения , которая принимает самые ранние , самые последние и нет в качестве параметров. Последний должен делать то, что вам нужно.

Примечание: , если вам все еще нужно GetKafka для работы с экземпляром Kafka 0.8, есть опция для Автоматический сброс смещения с возможными значениями наименьшее и наибольший .