初次使用spring连接kafka遇到的问题:org.apache.kafka.clients.networkclient broker may not be available

最近学习使用kafka用消息队列,在虚拟机上装了kafka,单机版,未做集群。

然后,用spring连接kafka,尝试发一条消息,刚玩起来就给报了警告,


控制台报的警告信息

2018-05-02 14:49:18.916 WARN 11916 --- [ntainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-4, groupId=cwenao-group] Connection to node 0 could not be established. Broker may not be available.

2018-05-02 14:49:20.098  WARN 11916 --- [ntainer#0-2-C-1] org.apache.kafka.clients.NetworkClient  : [Consumer clientId=consumer-3, groupId=cwenao-group] Connection to node 0 could not be established. Broker may not be available.

2018-05-02 14:49:20.104  WARN 11916 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient  : [Consumer clientId=consumer-1, groupId=cwenao-group] Connection to node 0 could not be established. Broker may not be available.

2018-05-02 14:49:20.146  WARN 11916 --- [ntainer#0-1-C-1] org.apache.kafka.clients.NetworkClient  : [Consumer clientId=consumer-2, groupId=cwenao-group] Connection to node 0 could not be established. Broker may not be available.

2018-05-02 14:49:20.375  WARN 11916 --- [ntainer#0-3-C-1] org.apache.kafka.clients.NetworkClient  : [Consumer clientId=consumer-4, groupId=cwenao-group] Connection to node 0 could not be established. Broker may not be available.

类似这样的信息是不断的报,不断的报,已经很明显,消息是发不成功的了。

在网上找了下,有童鞋说,可能是kafka配置没配好,kafka配置没有对外开放host、port


网上童鞋说的

原文链接:https://www.jianshu.com/p/ed9055bc68a6

好吧,我尝试一下看看,


原来的配置



修改后的配置

我已经把advertised.listeners配上了,配好后,把kafka重启,再跑spring应用。

这下好了,没有那个警告了,消息也正常发送成功了。


消息发送成功


好了,希望能帮助到同样是刚开始学习kafka的你^_^

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,308评论 19 139
  • ** 今天看了一下kafka官网,尝试着在自己电脑上安装和配置,然后学一下官方document。** Introd...
    RainChang阅读 10,434评论 1 30
  • 本文转载自http://dataunion.org/?p=9307 背景介绍Kafka简介Kafka是一种分布式的...
    Bottle丶Fish阅读 10,803评论 0 34
  • rljs by sennchi Timeline of History Part One The Cognitiv...
    sennchi阅读 12,130评论 0 10
  • 模块就好比工具包,要想使用这个工具包中的工具,就需要导入这个模块。 import 一import来引入模块,imp...
    界面大叔阅读 1,423评论 0 0