Hi, the rdkafka_performance tool from librdkafka's examples [1] lets you do this with something like: rdkafka_performance -P -b <broker> -t <topic> [-p <partition>] -r <msgs/s> -s <msgsize>
Thats the producer side, if you want performance measurements on the consumer side as well you do: rdkafka_performance -C -b <broker> -t <topic> -p <partition> -o <start_offset|beginning|end> There is an end-to-end latency measurement mode too where you run both producer and consumer simultaneously with the '-l' option. (this mode typically requires some config tweaking to get optimal results, e.g. minimize batch wait timing) Regards, Magnus [1]: https://github.com/edenhill/librdkafka 2015-02-25 19:46 GMT+01:00 Josh J <joshjd...@gmail.com>: > Hi, > > Is there a way to generate a specified amount of throughput? I'm using the > Stats class here > < > https://github.com/apache/kafka/blob/7130da90a9ee9e6fb4beb2a2a6ab05c06c9bfac4/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java > > > to > measure the throughput. Though I need to be able to precisely control the > amount of load. For example, 1000 records per second. > > Thanks, > Josh >
