【发布时间】：2020-11-20 20:06:01
【问题描述】：
我正在尝试将一个简单的 json 发布到一个 kafka 主题。我正在使用 apache nifi 和 apache kafka 的 dockerized 版本（两者都是最新的）。 kafka 版本是 2.5，但是没有处理器可以连接到这个版本。
当我使用其他 publishKafka 处理器时，我收到此错误：“无法在 5000 毫秒内更新元数据”。
谁能帮我解决这个问题？
【问题讨论】：
-
该错误通常意味着该主题不存在。您确定该主题存在吗？
-
感谢马修。是的，我在运行流程之前创建了主题。我也在主题列表中检查了它，它是可用的。我还手动发布了一些消息
-
它也可以是 Publish Kafka 处理器中的 Delivery Guarantee 属性。是否设置为尽力而为？我不相信它会在使用 Docker 实例的情况下正常工作。
-
我将事务设置为 false，因此它现在不需要保证属性。问题是否与此交易有关？
-
确认一下，您使用的是 PublishKafkaRecord_2_0, nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/…
标签： apache-kafka apache-nifi kafka-producer-api