Кафка отслеживает смещение на основе идентификатора группы потребителей (так называемый идентификатор группы в процессоре NiFi). Поэтому, если вы остановите и запустите процессор без изменения идентификатора группы, он всегда будет начинаться со следующего смещения для этого идентификатора группы.
В настоящее время NiFi не имеет способа запуска с указанным смещением c, но если вы измените идентификатор группы и выберете «Смещение сброса» как «самое раннее», то оно начнет потреблять с начала со смещением 0.
Как только данные будут получены из kafka и записаны в репозитории NiFi, смещение затем совершено. Таким образом, при перезапуске NiFi не требуется повторное рассмотрение этих сообщений, они уже хранятся локально в NiFi, и NiFi продолжит обрабатывать их с того места, где они были в потоке, когда вы перезапустили NiFi.