#apache-kafka #kafka-producer-api
#apache-kafka #kafka-producer-api
Вопрос:
Я хотел передать количество потоков, которые отправят сообщение Kafka broker в качестве аргумента в ProducerPerformance tool.
Ответ №1:
Вы не можете, вы должны увеличить или уменьшить пропускную способность на основе ваших тестов.
Инструмент производительности Kafka возьмет это на себя.
Ответ №2:
Глядя на исходный код, кажется, что он однопоточный.
Вы можете запустить несколько инструментов одновременно, как это, хотя
nohup kafka-run-class ... > run1.txt 2amp;>1 amp;
nohup kafka-run-class ... > run2.txt 2amp;>1 amp;
Комментарии:
1. Можем ли мы иметь что-то вроде передачи количества потоков в качестве параметра, который создаст такое количество потоков внутри для создания сообщений?
2. Такого параметра нет. Код находится на Github, если вы хотите взглянуть на него
3. github.com/becketqin/kafka/blob/KAFKA-3554/tools/src/main/java/… Здесь мы видим, что есть параметр для передачи количества потоков.
4. Это форк. Не официальный проект github.com/apache/kafka/blob/trunk/tools/src/main/java/org /…