For testing purposes, I need to simulate a client to generate 100,000 messages per second and send them to the kafka theme. Is there any tool or method that can help me generate these random messages?
There is a built-in tool for creating a dummy load located at bin/kafka-producer-perf-test.sh( https://github.com/apache/kafka/blob/trunk/bin/kafka-producer-perf-test.sh ). You can refer to https://github.com/apache/kafka/blob/trunk/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java#L106 to find out how to use it.
bin/kafka-producer-perf-test.sh
One use case would be:
bin/kafka-producer-perf-test.sh --broker-list localhost:9092 --messages 10000000 --topic test --threads 10 --message-size 100 --batch-size 10000 --throughput 100000
A key point is the flag --throughput 100000, which indicates that "the maximum throttle message volume is about 100,000 messages per second"
--throughput 100000
https://github.com/josephadler/eventsim, "" (, , : -P):
Eventsim - , . Scala, ( ). - ( - Spotify); , . , : . Apache Kafka., , , , . , , , , , , .
Eventsim - , . Scala, ( ). - ( - Spotify); , . , : . Apache Kafka.
, , , , . , , , , , , .
Source: https://habr.com/ru/post/1658203/More articles:Отключение защиты транспорта приложений и потенциальные перерывы клиента - securityAssertion does not work in php. So simple. What am I doing wrong? - phpGCC: How to completely disable heap usage on the MCU? - gccPHPUnit: how to mock multiple method calls with multiple arguments and without direct order? - unit-testingSpecify user folder path in VBA for Windows and Mac - vbaBitbucket Pipelines - mvn clean install does not work with JavaFX - dockerfunction marked # [no_mangle] but not exported - rustRandom forest with bootstrap = False in scikit-learn python - pythonCan we test the iOS notification on the Xcode 8 simulator without the participation of programmers? - iosProblem closing a database in Node.js using trireme-jdbc - node.jsAll Articles