org.apache.kafka.clients.NetworkClient Bootstrap broker (id: -3 rack: null) 在通过 NiFi 连接到 kafka consumer 时断开连接
org.apache.kafka.clients.NetworkClient Bootstrap broker (id: -3 rack: null) disconnected when connecting to kafka consumer via NiFi
我正在尝试使用 NiFi ConsumeKafka_2_6 处理器（NiFi 版本 1.12.1）在 Amazon MSK（Kafka 版本 2.2.1）上使用来自 kafka 主题的消息。在 ConsumeKafka 处理器中，我收到如下警告"org.apache.kafka.clients.NetworkClient [消费者 clientId=console-consumer-34567-5, groupId=nifi-consumer] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected”。导致此问题的原因是什么？这是由于使用的 kafka 客户端版本不匹配还是由于连接问题。
这是连接问题，或者您未正确配置 Nifi 处理器
您没有连接到 MSK，您正在尝试将 Nifi 连接到它自己
Bootstrap broker localhost:9092
此外，是的，使用带有 2.2 集群的 2_6 消费者可能会遇到一些问题，但这些问题很小，因为核心功能应该仍然有效
在 aws cli 中，我们使用 JVM 信任库与 MSK 集群通信。所以从 NiFi 应用程序我也应该使用它。我已将安全协议配置为 SSL，并在 SSLContextService 中配置了 JVM 信任库。然后我就可以消费来自 Kafka 的消息了。
我正在尝试使用 NiFi ConsumeKafka_2_6 处理器（NiFi 版本 1.12.1）在 Amazon MSK（Kafka 版本 2.2.1）上使用来自 kafka 主题的消息。在 ConsumeKafka 处理器中，我收到如下警告"org.apache.kafka.clients.NetworkClient [消费者 clientId=console-consumer-34567-5, groupId=nifi-consumer] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected”。导致此问题的原因是什么？这是由于使用的 kafka 客户端版本不匹配还是由于连接问题。
这是连接问题，或者您未正确配置 Nifi 处理器
您没有连接到 MSK，您正在尝试将 Nifi 连接到它自己
Bootstrap broker localhost:9092
此外，是的，使用带有 2.2 集群的 2_6 消费者可能会遇到一些问题，但这些问题很小，因为核心功能应该仍然有效
在 aws cli 中，我们使用 JVM 信任库与 MSK 集群通信。所以从 NiFi 应用程序我也应该使用它。我已将安全协议配置为 SSL，并在 SSLContextService 中配置了 JVM 信任库。然后我就可以消费来自 Kafka 的消息了。