You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by huxihx <gi...@git.apache.org> on 2017/09/06 02:45:00 UTC

[GitHub] kafka pull request #3188: KAFKA-5358: Consumer perf tool should count rebala...

GitHub user huxihx reopened a pull request:

    https://github.com/apache/kafka/pull/3188

    KAFKA-5358: Consumer perf tool should count rebalance time.

    Added 'join.group.ms' for new consumer to calculate the time of joining group. 
    
    @hachikuji  Please review the PR. Thanks.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/huxihx/kafka KAKFA-5358

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/kafka/pull/3188.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 #3188
    
----
commit be43bf3a1257ca5f058e38af3e185ba775749614
Author: amethystic <hu...@hotmail.com>
Date:   2017-06-01T09:15:15Z

    KAFKA-5358: Consumer perf tool should count rebalance time.
    
    Added 'join.group.ms' for new consumer to calculate the time of joining group.

commit cbdf6c10d12e1b0528dc45c078e61bb6ee1b0d2f
Author: amethystic <hu...@hotmail.com>
Date:   2017-06-02T07:11:03Z

    1. Refined the name to `total.rebalance.time`
    2. Added `total.fetch.time`
    3. Add support to count total time for multiple rebalances

commit 7600e6b994c251422444c905f5d4c718bf6f9935
Author: huxihx <hu...@hotmail.com>
Date:   2017-06-06T00:42:29Z

    Refined time counting for both fetcher and rebalance as per hachikuji's comments.

commit 08ff452fcb41136b54cfc2850540b18d737e909d
Author: huxihx <hu...@hotmail.com>
Date:   2017-06-07T06:27:00Z

    Correct the counting for total fetch time.

commit 8c80f1376dba7ac715fa0887e128293690a7014c
Author: huxihx <hu...@hotmail.com>
Date:   2017-06-08T01:31:49Z

    1. Split `MB.sec` into two parts: `total.MB.sec` and `fetch.MB.sec`
    2. Ditto for `nMsg.sec`
    3. Refined output format

commit edf1d0888728bc5c39b6ee59d23d3eed108243c6
Author: huxihx <hu...@hotmail.com>
Date:   2017-06-21T01:24:28Z

    returned back to the original output format for new consumer

commit 722e16df1b96275a04bd2e6a5e3deec476b028a6
Author: huxihx <hu...@hotmail.com>
Date:   2017-06-27T02:03:55Z

    As per hackikuji's comments, refined code to print out rebalance time even when  is set.

commit 57bd0e44723b681a191a12135e3cc60188c18e9d
Author: huxihx <hu...@hotmail.com>
Date:   2017-08-04T02:27:51Z

    resovled conflicts with trunk

commit 16cc2cab52c394ed4688fe377496cd98d1e2eb4b
Author: huxi <hu...@hotmail.com>
Date:   2017-08-04T03:42:17Z

    Merge branch 'trunk' into KAKFA-5358

commit 37982726a6fd09ef202eb428a2dd364aded1b929
Author: huxihx <hu...@hotmail.com>
Date:   2017-08-04T04:06:25Z

    KAFKA-5358: Did not show newly-created headers if `--show-detailed-stats` is set since rebalance time does not change during most of the consuming rounds.

commit bbba9b00a6538e69bc4261ed456a31993e42650e
Author: huxihx <hu...@hotmail.com>
Date:   2017-08-09T02:15:56Z

    correct printHeader invoking to have testHeaderMatchBody passed

commit 3a1ce0f8897577608182ffe1a8ce2f9bfbe41f55
Author: huxihx <hu...@hotmail.com>
Date:   2017-08-17T02:44:23Z

    Added newly-created fields for detailed views.

commit c51781586646664bb9514d8ab03aa974f9e6a942
Author: huxihx <hu...@hotmail.com>
Date:   2017-08-21T01:18:24Z

    1. Added parameter name when invoking testDetailedHeaderMatchBody; 2. Removed useless initialization for

commit 9adda74004c531894a31b7653529b32336682316
Author: huxihx <hu...@hotmail.com>
Date:   2017-09-06T02:41:42Z

    added a field that tracks periodic join time.

----


---