WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker 127.0.0.1:9092 disconnected
最新推荐文章于 2023-05-09 18:19:23 发布
学渣一枚12138
最新推荐文章于 2023-05-09 18:19:23 发布
阅读量4w
代码连接本地
kafka
没有问题 能监听到监听的topic，可获取通道中的所有topic
将
kafka
放到服务器上，本地程序启动报异常，可获取
kafka
中所有的topic，但是监听topic不起作用
启动时，报下面两个异常
Bootstrap
broker
localhost:
9092
(id: -1 rack: null)
dis
connect
ed
Connect
ion to node -1 (localhost/
127.0
.
0.1
:
9092
) could not be establi
这是一个惨痛的教训
就在昨天我和我四个同事因为这个问题搞到了夜里十一点半，啊啊啊啊啊！！！太恶心了！！！
在启动工程时，
kafka
报这个错误，在配置文件中配置
kafka
的依赖，和另一个服务器上配置的一模一样，但是在这个服务器上启动此工程就会出现这个问题????
问题原因：
kafka
的版本有问题，在另一个服务器上使用的是2.1版本的
kafka
，但是在此台服务器上使用的是2.6版本的
kafka
，所以需要添加一项配置来解决：
解决方案;
在配置文件中添加
kafka
配置：
spring.
kafka
.bootstr
开启了kerberos认证后
kafka
运行
kafka
-console-producer.sh和
kafka
-console-consumer.sh报错
Bootstrap
broker
host:ip (id: -1 rack: null)
dis
connect
ed
(
org
.
apache
.
kafka
.
client
s
.Net
work
Client
)
编辑$
KAFKA
_HOME/config/ 下的producer.properties和consumer.properties文件，在末尾添加认证方式
sasl.m
2020-08-19 22:55:56.089
WAR
N [-,,,] 35672 --- [ad | producer-1]
org
.
apache
.
kafka
.
client
s
.Net
work
Client
: [Producer
client
Id=producer-1] Error while fetching metadata with correlation id 483 : {abc_001=LEADER_NOT_AVAILABLE}
2020-08-19 22:55:56.205
WAR
N.
详细报错信息如下：
[root@
kafka
1 bin]# ./
kafka
-console-producer.sh -
broker
-list
kafka
1:
9092
,
kafka
2:
9092
,
kafka
3:
9092
-topic test
[2019-04-24 08:52:56,252]
WAR
N
Bootstrap
broker
kafka
2:
9092
dis
connect
ed
(
org
.apa...
位置：
org
.
apache
.
kafka
.
client
s;
作用：用于异步请求/响应网络i/o的网络客户端。这是一个内部类，用于实现面向用户的生产者和消费者客户端，也就是说我们的生产请求和消费请求最后都会交给Net
work
Client
类处理。
在sender线程中run时调用去。用于发送请求
通过连接处理实际的读写操作............
本博文中的IP都是随便写的。
公司整了一个新的环境，然后我要进行适配，结果发现对方有认证，无法直接使用，使用控制台生产和消费的时候报错。
[domain_realm][root@10-sh
kafka
-console-producer.sh --
broker
-list 12.12.12.27:
9092
--topic topic-test1
[2022-01-05 13:21:28,723]
WAR
N [Producer
client
Id=console-producer] Boot
在使用datax同步数据到
kafka
时一直报错
WAR
N Net
work
Client
- [Producer
client
Id=producer-1]
Bootstrap
broker
192.168.10
0.1
37:21005 (id: -1 rack: null)
dis
connect
ed
，
kafka
已设置非安全模式
WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker 127.0.0.1:9092 disconnected
40020
WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker 127.0.0.1:9092 disconnected
学渣一枚12138
