[KAFKA-4752] Streams Simple Benchmark MB/sec calculation is not correct for Join operations

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.11.0.0
• Fix Version/s: 0.11.0.0
• Component/s: streams
• Assignee: Eno Thereska
• Reporter: Damian Guy
• Created: 09/Feb/17 14:16
• Updated: 21/Feb/17 17:25
• Resolved: 21/Feb/17 17:25

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.

Issue Links

• links to: GitHub Pull Request #2551