我正在尝试使用 NiFi ConsumeKafka_2_6 处理器（NiFi 版本 1.12.1）在 Amazon MSK（Kafka 版本 2.2.1）上使用来自 kafka 主题的消息。在 ConsumeKafka 处理器中，我收到警告为“ org.apache.kafka.clients。 NetworkClient [Consumer clientId=console-consumer-34567-5, groupId=nifi-consumer] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected "。这个问题的原因是什么？这是由于版本使用的 kafka 客户端不匹配或由于连接问题。
问问题
2821 次
2 回答
0
这是连接问题，或者您错误地配置了 Nifi 处理器
您没有连接到 MSK，您正在尝试将 Nifi 连接到自身
引导代理本地主机：9092
另外，是的，使用 2.2 集群的 2_6 消费者可能会遇到一些问题，但非常小，因为核心功能应该仍然可以工作
于 2021-01-05T15:49:12.053 回答
0
在 aws cli 中，我们使用 JVM 信任库与 MSK 集群通信。所以从 NiFi 应用程序中，我也应该使用它。我已将安全协议配置为 SSL，并在 SSLContextService 中配置了 JVM 信任库。然后我就可以使用来自 Kafka 的消息了。
于 2021-01-12T07:00:09.490 回答