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

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

我的命令如下:

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测试端口没有问题,集群也可以正常的生产消息和接受消息。

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

发表于 2022-09-02
添加评论
1 records sent

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

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

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

你的答案

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