我想将发送消息给kafka代理的线程数作为producerperformance工具的参数。
ep6jt1vc1#
不能,必须根据测试增加或减少吞吐量。Kafka的性能工具将采取这一内部。
j7dteeu82#
看看源代码,它似乎是单线程的。不过,您可以像这样一次运行多个工具
nohup kafka-run-class ... > run1.txt 2&>1 & nohup kafka-run-class ... > run2.txt 2&>1 &
2条答案
按热度按时间ep6jt1vc1#
不能,必须根据测试增加或减少吞吐量。
Kafka的性能工具将采取这一内部。
j7dteeu82#
看看源代码,它似乎是单线程的。
不过,您可以像这样一次运行多个工具