如何在kafka producerperformance工具中传递多线程作为参数?

py49o6xq  于 2021-06-06  发布在  Kafka
关注(0)|答案(2)|浏览(338)

我想将发送消息给kafka代理的线程数作为producerperformance工具的参数。

ep6jt1vc

ep6jt1vc1#

不能,必须根据测试增加或减少吞吐量。
Kafka的性能工具将采取这一内部。

j7dteeu8

j7dteeu82#

看看源代码,它似乎是单线程的。
不过,您可以像这样一次运行多个工具

nohup kafka-run-class ... > run1.txt 2&>1 &
nohup kafka-run-class ... > run2.txt 2&>1 &

相关问题