我的 kafka 集群有 9 个节点。
Bcz 我正在尝试实现 SSL，我目前正在尝试仅在 1 个节点上设置 SSL。
现在，当我为 id 为 1001 的节点完成 SSL 设置并对此进行测试时，我创建了一个主题“SSLtest”，该主题仅在 1001 上具有领导者和副本。
当我尝试将数据从同一台机器上的控制台生产者推送到主题“SSLtest”（即 1001）时，它会尝试连接机器 1006，如日志所示：
Error when handling request {topics=[SSLtest],allow_auto_topic_creation=true} (kafka.server.KafkaApis)
kafka.common.BrokerEndPointNotAvailableException: End point with listener name SSL not found for broker 1006.
为什么不能直接将数据推送到1001。它试图在 1006 上做什么。