为什么我的nifi publishkafka处理器只能与以前的版本一起工作？

bttbmeg0 于 2021-06-06 发布在 Kafka

关注(0)|答案(0)|浏览(374)

我使用的是kafka 2，出于某种原因，唯一能将我的消息正确发布到kafka的nifi处理器是publishkafka（0\u 9）和publishkafka（0\u 10）。以后的版本不会将我的消息推送出去，这很奇怪，因为我运行的是Kafka2.1.1。
有关更多信息，当我尝试通过稍后发布的kafka处理器运行我的flowfile时，我得到了一个大量重复的超时异常。

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.

我的处理器设置如下：

所有其他配置都是默认配置。你知道为什么会这样吗？