Я использую Kafka 2, и по какой-то причине единственными процессорами NiFi, которые будут правильно публиковать мои сообщения в Kafka, являются PublishKafka (0_9) и PublishKafka_0_10. Более поздние версии не пропускают мои сообщения, что странно, потому что я снова запускаю Kafka 2.1.1.
Для получения дополнительной информации, когда я пытаюсь запустить FlowFile через более поздние процессоры PublishKafka, я получаю исключение тайм-аута, которое многократно повторяется.
2019-03-11 16:05:34,200 ERROR [Timer-Driven Process Thread-7] o.a.n.p.kafka.pubsub.PublishKafka_2_0 PublishKafka_2_0[id=6d7f1896-0169-
1000-ca27-cf7f86f22694] PublishKafka_2_0[id=6d7f1896-0169-1000-ca27-
cf7f86f22694] failed to process session due to
org.apache.kafka.common.errors.TimeoutException: Timeout expired while
initializing transactional state in 5000ms.; Processor Administratively
Yielded for 1 sec: org.apache.kafka.common.errors.TimeoutException:
Timeout expired while initializing transactional state in 5000ms.
org.apache.kafka.common.errors.TimeoutException: Timeout expired while
initializing transactional state in 5000ms.
2019-03-11 16:05:34,201 WARN [Timer-Driven Process Thread-7]
o.a.n.controller.tasks.ConnectableTask Administratively Yielding
PublishKafka_2_0[id=6d7f1896-0169-1000-ca27-cf7f86f22694] due to uncaught
Exception: org.apache.kafka.common.errors.TimeoutException: Timeout
expired while initializing transactional state in 5000ms.
Мои настройки процессора следующие:
Все остальные конфигурации являются настройками по умолчанию.
Любые идеи о том, почему это происходит?