kafka自带压力测试报org.apache.kafka.common.errors.TimeoutException

没干嘛 发表于: 2022-09-02   最后更新时间: 2022-09-02 19:50:03   1,075 游览

我的命令如下：

bin/kafka-producer-perf-test.sh --topic test01 --num-records 1000 --record-size 10 --throughput -1  --producer-props bootstrap.servers=kafka:9092

报错如下：

1 records sent, 0.0 records/sec (0.00 MB/sec), 60001.0 ms avg latency, 60001.0 max latency.
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

防火墙和selinux都关闭了，并且telnet测试端口没有问题，集群也可以正常的生产消息和接受消息。

有没有那个大佬知道是为什么呢？

kafka
发表于 2022-09-02
没干嘛
添加评论 
1 records sent

发送第一个消息，就报错了，说明你这个kafka集群网络本身就有问题，并不是你压测命令的问题。

你可以用最基本的生产者和消费者命令进行测试，命令参考：kafka命令大全

Timeout异常，可查看kafka TimeoutException 解决。

回复
回答于 2年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。