试着在Kafka用 kafka-consumer-perf-test.sh ，并且总是出现以下错误：
警告：在使用预期的消息数之前退出：超过超时（100000毫秒）。您可以使用--timeout选项来增加超时时间。
我的命令：
./kafka-consumer-perf-test.sh --topic perf_test --broker-list $myhost:9092 --messages 10000000 --threads 2 --print-metrics --show-detailed-stats
2条答案
按热度按时间y1aodyip1#
要避免此类警告，在运行此命令之前，必须至少生成10000000条指向该主题的消息。
cgyqldqp2#
可能有两个原因：
由于过载，您的kafka示例无法在100秒内使用2个线程消耗10000000条消息。您可以考虑：
监视你的Kafka示例看看引擎盖下发生了什么
增加读卡器线程数
增加超时
您试图阅读的主题中没有消息，读者尝试使用预期数量的消息，并在1分40秒后失败/退出
您可能还对使用专用的负载测试工具感兴趣，即apachejmeter，它不支持kafka负载测试，但可以通过pepperbox插件启用。查看ApacheKafka-HowtoLoadTestwithJMeter文章了解详细信息。
使用负载测试工具，您将提供更多信息，您将能够看到具有性能指标的表/图表，这些性能指标允许将不断增加的负载与主题队列或代理资源消耗中不断增加的消息数量相关联