Как передать несколько потоков в качестве аргумента в инструменте Kafka ProducerPerformance?

Question

Я хотел передать количество потоков, которые будут отправлять сообщение брокеру Kafka в качестве аргумента для инструмента ProducerPerformance.

Answer 1

Глядя на исходный код, он кажется однопоточным.

Вы можете запустить несколько инструментов одновременно, как это, хотя

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

Answer 2

Вы не можете, вы должны увеличивать или уменьшать пропускную способность на основе ваших тестов.Инструмент производительности Kafka примет это внутренне.