org.apache.kafka.clients.NetworkClient引导代理(id:-3 rack:null)在



我正试图使用NiFi ConsumeKafka_2_6处理器(NiFi 1.12.1版(在Amazon MSK(kafka 2.2.1版(上消费来自kafka主题的消息org.apache.kafka.clients.NetworkClient[Consumer-clientId=console-Consumer-34567-5,groupId=nifi Consumer]引导代理localhost:9092(id:-1 rack:null(已断开连接"。这个问题的原因是什么?这是由于使用的kafka客户端版本不匹配还是由于连接问题。

这是连接问题,或者您错误地配置了Nifi处理器

你没有连接到MSK,你试图将Nifi连接到

引导代理localhost:9092

此外,是的,使用带有2.2集群的2_6消费者可能会遇到一些问题,但非常小,因为核心功能应该仍然可以工作

从aws-cli,我们使用JVM信任库与MSK集群进行对话。所以在NiFi应用程序中,我也应该使用它。我已经将安全协议配置为SSL,并在SSLContextService中配置了JVM信任库。然后我就可以使用卡夫卡的信息了。

导致此错误的原因可能有多种。在我的情况下,启用了AWS MSK IAM身份验证,在运行kafka-console-consumer.sh脚本--consumer.config path/to/client.properties时,我缺少client.properties文件

最新更新