要让Kafka运行,您需要在config/server.properties文件中设置一些属性.我不明白有两种设置.
有人可以解释一下监听器和advertised.listeners属性之间的区别吗？
文件说:
listeners:套接字服务器侦听的地址.
和
advertised.listeners:代理将向生产者和消费者做广告的主机名和端口.
我何时必须使用哪种设置？
我一直在尝试使用Helm 图表来部署 Kafka 。所以我为 Kafka Pod 定义了 NodePort 服务。我使用相同的主机和端口检查了控制台 Kafka 生产者和消费者 - 它们工作正常。但是，当我创建 Spark 应用程序作为数据消费者并创建 Kafka 作为生产者时，它们无法连接到 Kafka service0。我使用 minikube ip （而不是节点 ip）作为主机和服务 NodePort 端口。尽管在 Spark 日志中，我看到 NodePort 服务解析端点，并且代理被发现为 pod 寻址和端口：
INFO AbstractCoordinator: [Consumer clientId=consumer-1, groupId=avro_data] Discovered group coordinator 172.17.0.20:9092 (id: 2147483645 rack: null)
INFO ConsumerCoordinator: [Consumer clientId=consumer-1, groupId=avro_data] Revoking previously assigned partitions []
INFO AbstractCoordinator: [Consumer clientId=consumer-1, groupId=avro_data] (Re-)joining group
WARN NetworkClient: [Consumer clientId=consumer-1, groupId=avro_data] Connection to node 2147483645 (/172.17.0.20:9092) could not be established. Broker may not …