GitHub user granders opened a pull request:
https://github.com/apache/kafka/pull/179
KAFKA-2489: add benchmark for new consumer
@ewencp
The changes here are smaller than they look - mostly refactoring/cleanup.
- ConsumerPerformance.scala - corrected timeout inequality which had
prevented this from working with new consumer
- ConsumerPerformanceService: added new_consumer flag, and exposed more
command-line settings
- benchmark.py: refactored to use `@parametrize` and `@matrix` - this
reduced some amount of repeated code
- benchmark.py: added consumer performance tests with new consumer (using
`@parametrize`)
- benchmark.py: added more detailed test descriptions
- performance.py: broke into separate files
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/confluentinc/kafka
KAFKA-2489-benchmark-new-consumer
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/179.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #179
----
commit 6525594e2c4803f85403f260ddcb18ff5ae6c0a0
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-29T05:24:29Z
Fixed typo in ProducerPerformance.java
commit fa5f81094215a69f00076cc2a07c2e3d19f9a34f
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-29T05:25:53Z
Fixed ConsumerPerformance.scala with new consumer: incorrect inequality
previously caused this to time out without consuming any messages with new
consumer.
commit 45b31f3d5f7a2ae6d4d27737012495cc8ad1c70d
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-29T05:28:57Z
Updated consumer throughput tests to run with new and old consumer.
Refactored with @parametrize and @matrix to reduce duplicated code.
commit f4d837330fdda2bc7918b97e740ba91a9d456462
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-29T05:30:37Z
Refactored performance.py - broke services into individual files. This does
not change the way external users would import and use the performance services
however.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
