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

["Damian Guy (JIRA)" <ji...@apache.org>]

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)