Description
When benchmarking join operations via the SimpleBenchmark we produce 2 * numRecords, i.e, numRecords to topic1 and numRecords to topic2.
The CountDownLatch in the foreach keeps processing until it has received numRecords. As this is the numRecords produced from the join, the size of each record will either be VALUE_SIZE or 2 * VALUE_SIZE. The MB/s calculation doesn't take this into account.
Attachments
Issue Links
- links to