benchmark
benchmark copied to clipboard
openmessaging
OpenMessaging Benchmark Framework
Hi guys, many thanks for your work, it's an amazing tool to compare brokers performances. I've seen a couple of really nice brokers emerging these days: - On K8s I've...
# Motivation It'd be useful to be able to correlate benchmark metrics with broker and system metrics. To do so we'd need to expose the benchmark metrics so that they...
Is there a way to configure a static topic name when running the benchmark? We would like to run producer and consumer workload independently to measure producer and consumer throughput...
We've recently added a GitHub Actions build (#307) and included a number of code quality checks (#309). All code coverage levels are currently set to 0, however we do have...
Sometimes, the worker process will hang when it fails to start. This may give the erroneous impression that the worker is ready when it is not. One example of this...
If an exception in the driver during a run (e.g., some `sendPost` method fails, e.g., because the configuration was invalid) the driver will hang, at least when using multiple distributed...
I am interested to run the open messaging tests of the driver-kafka on an Openshift cluster. Has anyone tried it? can we use the same yaml file to run the...
In the Kafka driver, we find the [following code](https://github.com/openmessaging/benchmark/blob/8294b0a38c3aae0c6e93dcfaf0cec8f378077f09/driver-kafka/src/main/java/io/openmessaging/benchmark/driver/kafka/KafkaBenchmarkDriver.java#L90-L102) in `initialize`: ``` if (config.reset) { // List existing topics ListTopicsResult result = admin.listTopics(); try { Set topics = result.names().get(); //...
The original code and fix are as follows. ``` public CompletableFuture createProducer(String topic) { if (config.producerType.equals(ClientType.KAFKA)) { final BenchmarkProducer producer = new KafkaBenchmarkProducer(new KafkaProducer(producerProperties), topic); producers.add(producer); return CompletableFuture.completedFuture(producer); } else...
**Problem**: I am trying to use Openmessaging Benchmark for the performance testing of our in-house message broker. However, we have strict message schema validation, so probing the producers doesn't work...
