昆明java培训
达内昆明广州春城路

18487146383

热门课程

kafka需要注意的事项

  • 时间:2016-10-21
  • 发布:昆明Java培训
  • 来源:达内新闻

昆明Java培训的老师提醒大家kafka需要注意的事项。

7.1 producer无法发送消息的问题

最开始在本机搭建了kafka伪集群,本地producer客户端成功发布消息至broker。随后在服务器上搭建了kafka集群,在本机连接该集群,producer却无法发布消息到broker(奇怪也没有抛错)。最开始怀疑是iptables没开放,于是开放端口,结果还不行(又开始是代码问题、版本问题等等,倒腾了很久)。最后没办法,一项一项查看server.properties配置,昆明Java培训的老师发现以下两个配置:

# The address the socket server listens on. It will get the value returned from

# java.net.InetAddress.getCanonicalHostName() if not configured.

#  FORMAT:

#    listeners = security_protocol://host_name:port

#  EXAMPLE:

#    listeners = PLAINTEXT://your.host.name:9092

listeners=PLAINTEXT://:9092

# 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().

#advertised.listeners=PLAINTEXT://your.host.name:9092

以上说的就是advertised.listeners是broker给producer和consumer连接使用的,如果没有设置,就使用listeners,而如果host_name没有设置的话,就使用java.net.InetAddress.getCanonicalHostName()方法返回的主机名。

修改方法:

1. listeners=PLAINTEXT://121.10.26.XXX:9092

2. advertised.listeners=PLAINTEXT://121.10.26.XXX:9092

修改后重启服务,正常工作。

昆明达内Java培训汇集Java培训行业专家,学Java开发就到昆明达内Java培训班!

上一篇:kafka知识点:consumer消费消息
下一篇:快速排序(QuickSort)-Java实现

昆明java培训教你实现JSP页面跳转简易方法,120天后月薪过万

昆明Java培训告诉你java和大数据和互联网发展中起什么作用

昆明java培训:初学者学Java Script 5个小技巧

昆明java培训多久可以学会?120天教你成为java开发大神!

选择城市和中心
贵州省

广西省

海南省

扫一扫

了解更多干货