Kafka消费者测试总是失败

Question

我正在尝试对我的 Kafka 集群执行性能测试，但它总是失败。这是日志

bin/kafka-consumer-perf-test.sh --topic test --broker-list localhost:9092,localhost:9093,localhost:9094 --messages 500 --timeout 1000000

start.time, end.time, data.consumed.in.MB, MB.sec, data.consumed.in.nMsg, nMsg.sec, rebalance.time.ms, fetch.time.ms, fetch.MB.sec, fetch.nMsg.sec

警告：在消耗预期数量的消息之前退出：超出超时（1000000 毫秒）。您可以使用 --timeout 选项来增加超时。 2020-07-02 17:23:52:304, 2020-07-02 17:40:32:625, 0.0000, 0.0000, 11, 0.0110, 1593690832494, -1593689832173, -0.0000, -0.0000

每当我增加超时选项并减少消息参数时，我也没有得到结果。

Answer 1

从输出来看，您的主题似乎只产生了11条记录，因此该工具无法消耗500条记录而不得不选择超时。

如果您只是对警告感到恼火，请尝试以下命令：

> bin/kafka-consumer-perf-test.sh --topic test \
--broker-list localhost:9092,localhost:9093,localhost:9094 \
--messages 11 --timeout 1000000

Kafka消费者测试总是失败

Kafka Consumer test always fail

apache-kafka

kafka-consumer-api