返回到文章

采纳

编辑于 2年前

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

kafka

我的命令如下:

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

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