У нас работает кластер с 6 узлами. Теперь, когда я добавляю потребителя Kafka, каждый узел кластера должен извлекать уникальные данные, как в каждом узле должен извлекать данные из раздела diff: https://bryanbende.com/development/2016/09/15/apache-nifi-and-apache-kafka.
То же самое упоминается в документах nifi. Однако в нашем случае каждый узел извлекает одни и те же данные из Кафки, что приводит к дублированию. Может кто-нибудь, пожалуйста, помогите. Есть ли какие-то конкретные конфигурации, необходимые для того же?