我想传递将消息发送到 Kafka 代理的线程数量,作为 ProducerPerformance 工具的参数。
不能,必须根据测试增加或减少吞吐量。
Kafka 性能工具将在内部利用这一点。
查看源代码,它似乎是单线程的。
不过,您可以像这样一次运行多个工具
nohup kafka-run-class ... > run1.txt 2&>1 &
nohup kafka-run-class ... > run2.txt 2&>1 &