【解决方案】kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
终端中报错kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
同时Kafka启动时报错: Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
解决方法:
检查自己的zookeeper和kafka是否都已开启,且均已管理员方式启动cmd,在对应的文件目录下启动zookeeper和kafka
// 1. 启动zookeeper
F:\kafka\kafka_2.12-2.8.0\bin\windows> zookeeper-server-start.bat F:\kafka\kafka_2.12-2.8.0\config\zookeeper.properties
// 2. 启动kafka
F:\kafka\kafka_2.12-2.8.0\bin\windows> kafka-server-start.bat F:\kafka\kafka_2.12-2.8.0\config\server.properties
// 3. 启动程序
两个终端中分别启动zookeeper和kafka、效果显示分别如下:
终端中没有拒绝连接和连接自动关闭等异常消息,则说明启动成功。
第三步启动程序,向kafka发送消息:
成功连接并且发送消息,在相应目录下会生成一个web_log文件夹,表示有一个分区
此时代表成功发送消息,问题解决!
【解决方案】kafka: client has run out of available brokers to talk to (Is your cluster reachable?)相关推荐
- [ERROR] sarama.NewSyncProducer error:kafka: client has run out of available brokers to talk to (Is y
[ERROR] sarama.NewSyncProducer error:kafka: client has run out of available brokers to talk to (Is y ...
- go连接Kafka报错kafka: client has run out of available brokers to talk to
问题出现的场景: 有个go写的项目,原来是用go vendor来管理依赖包的,现在改为是用go module方式了,转换之后,编译成功,发现了上面的错误.很显然连接kafka集群报错了. 问题的原因: ...
- Golang连接kafka报错: Errorkafka: client has run out of available brokers to talk to
用到的go包: "github.com/Shopify/sarama" 详细的报错内容如下: 2022/10/28 15:39:25 Error creating consumer ...
- 记录解决启动prometheus-kafka-adapter提示“client has run out of available brokers to talk to“的问题
目录 现象描述 排查过程 踩坑总结 参考 现象描述 用别人构建好的prometheus-kafka-adapter二进制文件,在服务器上按照文档提示配置KAFKA_BROKER_LIST环境变量,启动 ...
- Win10配置Kafka以及Zookeeper环境(run out of available brokers错误解决)
背景 在某实验项目中,需要部署一个日志采集系统,其中需要用到Java环境.kafka.zookeeper中间件,其中kafka.zookeeper均部署到本地,本文主要记录环境配置过程. 版本信息: ...
- Windbg调优Kafka.Client内存泄露
从来没写过Blog,想想也是,工作十多年了,搞过N多的架构.技术,不与大家分享实在是可惜了.另外,从传统地ERP行业转到互联网,也遇到了很所前所未有的问题,原来知道有一些坑,但是不知道坑太多太深.借着 ...
- .net Kafka.Client多个Consumer Group对Topic消费不能完全覆盖研究总结(二)
依据Partition和Consumer的Rebalance策略,找到Kafka.Client Rebalance代码块,还原本地环境,跟踪调试,发现自定义Consumer Group 的Consum ...
- .net Kafka.Client多个Consumer Group对Topic消费不能完全覆盖研究总结(一)
我们知道Kafka支持Consumer Group的功能,但是最近在应用Consumer Group时发现了一个Topic 的Partition不能100%覆盖的问题. 程序部署后,发现Kafka在p ...
- 连接kafka报错:1 partitions have leader brokers without a matching listener
服务输出部分错误日志截图 2020/12/25 下午2:32:442020-12-25 14:32:44.320 WARN [tag-service,,,] 1 --- [ntainer#4-0-C- ...
最新文章
- 实战:使用Telnet排除网络故障
- BZOJ2054: 疯狂的馒头(并查集)
- laravel简单的laragon环境搭建不需要composer一键集成
- 实现基于内核栈切换的进程切换-linux011
- GPS测量原理与应用_第四版_徐绍铨_武汉大学出版社_考试复习资料
- ICMP协议详解和作用
- 解决deep freeze冰点还原软件无法冻结的问题:计算机正在完成Deep Freeze冰点检测到的待定Windows更新
- 浅谈Java的类和封装
- 懒人神器,IDEA插件之EasyCode,自动生成CRUD代码
- Fragment already added 解决方式
- PC端如何使用ITunes无线连接ios手机
- Android仿朋友圈照片定点放大和滑动查看(未完待续)
- 【Mark】黑客与画家 - 第一章 为什么书呆子不受欢迎
- 加速安装pytorch
- Deprecated:function eregi() is deprecated in /usr/local/apache/libraries/lib_lang.php on line 8
- 【P9】Point to the Expression:Solving Algebraic Word Problems using the Expression-Pointer Transformer
- 【程序23】 	题目:有5个人坐在一起,问第五个人多少岁?他说比第4个人大2岁。 	问第4个人岁数,他说比第3个人大2岁。问第三个人,又说比第2人大 	两岁。问第2个人,说比第一个人大两岁。最后问第一
- 第三课 大数据技术之Fink1.13的实战学习-时间和窗口
- 按键控制步进电机转速(led闪烁)学习心得
- 什么是多天线MIMO?