关于Java连接虚拟机中的Kafka时,无法发送、接收消息的问题
2018-03-08 15:14
1766 查看
自己在使用Java编写Kafka的Producer端和Consumer端时,Consumer端无法接收消息,而Producer端可以发送消息。参考网上大神的解决办法,总算得到解决。
修改后为:advertised.listeners=PLAINTEXT://192.168.22.131:9092之后重启kafka。Producer和Consumer就能够通信了。
Hostname and port the broker will advertise to producers and consumers.If not set, it uses the value for "listeners" if configured.Otherwise, it will use the value returned from java.net.InetAddress.getCanonicalHostName().翻译为:代理会将主机地址和端口号广播给生产者和消费者。如果没有设置,它将会用“listeners”的值,如果”listeners“设置了的话。否则,他将返回java.net.InetAddress.getCanonicalHostName()的值。
所以第二中方法就是修改“listeners“这个地方,而上面就不需要修改了。
参考:http://blog.csdn.net/zhaominpro/article/details/79068141
十分感谢大神给的思路!
开发环境:
JDK | 1.8 |
Kafka | 2.11 |
操作系统 | win 10 |
虚拟机 | Ubuntu 16.04 |
解决办法:
修改kafka目录->config->server.properties文件。找到当前位置# The address the socket server listens on. It will get the value returned from # java.net.InetAddress.getCanonicalHostName() if not configured. # FORMAT: # listeners = listener_name://host_name:port # EXAMPLE: # listeners = PLAINTEXT://your.host.name:9092 #listeners=PLAINTEXT://:9092将当前位置去掉注释,修改your.host.name为当前虚拟机的ip地址。我当前的地址为192.168.22.131。
修改后为:advertised.listeners=PLAINTEXT://192.168.22.131:9092之后重启kafka。Producer和Consumer就能够通信了。
Hostname and port the broker will advertise to producers and consumers.If not set, it uses the value for "listeners" if configured.Otherwise, it will use the value returned from java.net.InetAddress.getCanonicalHostName().翻译为:代理会将主机地址和端口号广播给生产者和消费者。如果没有设置,它将会用“listeners”的值,如果”listeners“设置了的话。否则,他将返回java.net.InetAddress.getCanonicalHostName()的值。
所以第二中方法就是修改“listeners“这个地方,而上面就不需要修改了。
# The address the socket server listens on. It will get the value returned from # java.net.InetAddress.getCanonicalHostName() if not configured. # FORMAT: # listeners = listener_name://host_name:port # EXAMPLE: # listeners = PLAINTEXT://your.host.name:9092 #listeners=PLAINTEXT://:9092找到当前代码段,修改红色部分为listeners=PLAINTEXT://192.168.22.131:9092。192.168.22.131为当前主机的ip地址。作用与上面是一样的,大家根据喜好自行选择修改吧。
参考:http://blog.csdn.net/zhaominpro/article/details/79068141
十分感谢大神给的思路!
相关文章推荐
- 关于xshell无法连接虚拟机上的centos问题
- kafka java中发送数据、连接失败问题解决
- 关于java使用网易服务器smtp.163.com发送邮件,连接失败的问题
- kafka java中发送数据、连接失败问题解决
- 关于百度云、极光的推送的问题,为什么控制台发送消息成功,而手机端接收不到消息
- 关于接入第三方推送,国产手机无法接收到推送消息的的问题
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka java中发送数据、连接失败问题解决
- kafka发送消息出现的问题KafKa error java.nio.channels.UnresolvedAddressException
- kafka 0.10.2 解决java无法生产消息到指定topic问题
- kafka java中发送数据、连接失败问题解决
- 关于无法接收消息推送问题的修改
- kafka java中发送数据、连接失败问题解决
- 关于kafka的新的group无法订阅到topic中历史消息的问题