【发布时间】:2019-05-17 17:32:34
【问题描述】:
我已安装 kafka_2.11-1.1.0 并将广告侦听器设置为 advertised.listeners=PLAINTEXT://<my-ip>:9092(在 $KAFKA_HOME/config/server.properties 中)。
我可以使用 java 代码连接并写入我的 kafka,并通过 kafka-tool 从另一台服务器查看我的集群,但我无法从本地机器(我在其上安装 kafka 集群的机器)向我的主题写入消息)。
我也尝试将 listeners 值设置为 listeners = PLAINTEXT://:9092,但没有任何变化。我应该如何处理我的 kafka 以使其在本地主机外部和内部都可访问和可写?
【问题讨论】:
-
“我无法从本地机器向我的主题写入消息”-> 您是否收到错误消息?你打算怎么写?
-
我尝试编写一个类似于此处描述的示例的应用程序:dzone.com/articles/kafka-producer-and-consumer-example 我的意思是来自 java 代码。
-
你能显示端口 9092 的 netstat 输出吗?再说一遍,您是否遇到了错误?
-
我使用 telned 从这台服务器到它自己 (
telnet localhost 9092),它告诉我Trying 127.0.0.1... Connected to localhost.,按回车后它说Connection to localhost closed by foreign host.。我应该用 netstat 做什么?
标签: apache-kafka kafka-consumer-api kafka-producer-api