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