Damian Guy created KAFKA-4752: --------------------------------- Summary: Streams Simple Benchmark MB/sec calculation is not correct for Join operations Key: KAFKA-4752 URL: https://issues.apache.org/jira/browse/KAFKA-4752 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.3.0 Reporter: Damian Guy Assignee: Eno Thereska Priority: Minor Fix For: 0.10.3.0
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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)