Попытка запустить тест производительности потребителя в версии Kafka 2.1.0.Команда, которую я пытаюсь выполнить, выглядит следующим образом:
./bin/kafka-consumer-perf-test.sh --broker-list localhost:9092 --topic shopInfo --messages 10 --timeout 100000
Тест возвращает ошибку тайм-аута, но даже если я изменяю тайм-аут, я получаю такой же ответ на ошибку, как показано ниже.
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
WARNING: Exiting before consuming the expected number of messages: timeout (100000 ms) exceeded. You can use the --timeout option to increase the timeout.
2019-09-22 19:04:24:825, 2019-09-22 19:06:04:929, 0.0000, 0.0000, 0, 0.0000, 0, 100104, 0.0000, 0.0000
Присутствует только несколько потребителей, которые пытаются выполнить тест по неактивной теме теста в активном кластере.