2 qq 20550055 qq_20550055 于 2016.04.20 12:17 提问

kafka集群 报错 在线等

WARN [Controller-1-to-broker-2-send-thread], Controller 1's connection to broker Node(2, mine-28, 9092) was unsuccessful (kafka.controller.RequestSendThread)
java.io.IOException: Connection to Node(2, mine-28, 9092) failed
at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$1.apply(NetworkClientBlockingOps.scala:62)
at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$1.apply(NetworkClientBlockingOps.scala:58)
at kafka.utils.NetworkClientBlockingOps$$anonfun$kafka$utils$NetworkClientBlockingOps$$pollUntil$extension$2.apply(NetworkClientBlockingOps.scala:106)
at kafka.utils.NetworkClientBlockingOps$$anonfun$kafka$utils$NetworkClientBlockingOps$$pollUntil$extension$2.apply(NetworkClientBlockingOps.scala:105)
at kafka.utils.NetworkClientBlockingOps$.recurse$1(NetworkClientBlockingOps.scala:129)
at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntilFound$extension(NetworkClientBlockingOps.scala:139)
at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:105)
at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:58)
at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:225)
at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172)
at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

2个回答

CSDNXIAOD
CSDNXIAOD   2016.04.20 12:22

kafka集群安装配置
----------------------biu~biu~biu~~~在下问答机器人小D,这是我依靠自己的聪明才智给出的答案,如果不正确,你来咬我啊!

qq_20550055
qq_20550055   2016.04.20 12:29

木有人遇到吗? 每次第一台启动的都报这个错,第二台kafka正常,后面启动的正常了 ,前面启动的还一直报这样的错误,

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
Kafka集群的测试和简单试用
应用场景 按照Hadoop完全分布式安装Kafka博文搭建完Kafka2.11集群后,需要简单试用,来体会Kafka的工作原理,以及如何进行使用,感受分布式消息队列系统。 操作步骤思路:搭建了三个节点的Kafka集群,在主节点创建一个topic,作为生产者,两个从节点作为消费者分别看看能否接收数据,进行验证步骤一,在主节点执行创建topic及查看topic命令#查看所有topic命令如下 #
Kafka学习整理九(集群的扩容)
Kafka学习整理九(集群的扩容)
kafka集群broker节点扩容方案
在用kafka集群有3个节点,即host1, host2, host3,现需要将broker节点扩容至6个,以提供更高的数据处理能力。 一、上架一台物理服务器用于提供更多的资源 新扩容3个broker节点,host4,host5,host6 二、在三台新增节点上部署kafka应用程序 这些不是本文的重点,略过。 三、重新分布原有的topic分区 1、查看集群中当
apache kafka系列之迁移与扩容工具用法
本篇blog教你如果使用kafka工具进行迁移和扩容相关topic。
kafka消息队列集群安装说明
zookeeper集群安装,kafka消息队列集群安装说明,kafka消息队列集群安装说明kafka消息队列集群安装说明
Centos7 安装Kafka集群
准备好三台主机: Node-131 Node-132 Node-133 下载解压:从官网下载Kafka 安装包,解压安装: tar zxvf kafka_xxx.tgz mv kafka_xxx kafka cd kafka启动Zookeeper集群zookeeper集群搭建参考之前的文章 http://blog.csdn.net/sunjiaminaini/article/deta
搭建kafka集群详细教程
搭建kafka集群详细教程搭建kafka集群详细教程搭建kafka集群详细教程
kafka集群启动遇到LeaderNotAvailableException错误
解决方法很简单,用zookeeper client删除下面的路径/brokers/topic/${topic-name}kafka 0.8.1自带的zookeeper-shell.sh程序很麻烦,需要一点点删除delete /brokers/topics/test/partitions/0 delete /brokers/topics/test/partitions delete /brokers
Kafka集群搭建详细步骤
Kafka集群搭建 1、 Kafka的安装需要java环境,cent os 7自带java1.6版本,可以不用重新安装,直接使用自带的jdk 即可;如果觉得jdk版本太旧,也可以自己重新安装; 2、 准备好kafka安装包,官网下载地址: http://kafka.apache.org/downloads.html 3、 下
kafka集群扩容(Topic迁移)
文章新地址 文章开始前推荐使用 kafka-manager 工具,可以实时查看kafka同步状态,broker实时读写流量,topic分区情况等信息,提供重选最优leader等操作。 kafka的集群扩容实际上就是把 topic 的 partition 移动到新加的集群上。生成 topic 移动 json文件有两种方式: 通过 --topics-to-move-json-file 和 --bro