Мне было интересно, существует ли в Apache Nifi процессор, который просматривает «текущее» (т. Е. Где сейчас смещение) событие из Apache Kafka topi c, но без перемещения смещения к следующему событию в Кафке.
Нет процессора, который в настоящее время делает это. Процессоры-потребители записывают данные в репозитории NiFi и фиксируют эту операцию, а затем фиксируют смещения в Kafka, чтобы гарантировать, что NiFi получит данные до фиксации смещений.