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 <huxi...@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 <huxi...@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 <huxi...@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 <huxi...@hotmail.com> Date: 2017-06-07T06:27:00Z Correct the counting for total fetch time. commit 8c80f1376dba7ac715fa0887e128293690a7014c Author: huxihx <huxi...@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 <huxi...@hotmail.com> Date: 2017-06-21T01:24:28Z returned back to the original output format for new consumer commit 722e16df1b96275a04bd2e6a5e3deec476b028a6 Author: huxihx <huxi...@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 <huxi...@hotmail.com> Date: 2017-08-04T02:27:51Z resovled conflicts with trunk commit 16cc2cab52c394ed4688fe377496cd98d1e2eb4b Author: huxi <huxi...@hotmail.com> Date: 2017-08-04T03:42:17Z Merge branch 'trunk' into KAKFA-5358 commit 37982726a6fd09ef202eb428a2dd364aded1b929 Author: huxihx <huxi...@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 <huxi...@hotmail.com> Date: 2017-08-09T02:15:56Z correct printHeader invoking to have testHeaderMatchBody passed commit 3a1ce0f8897577608182ffe1a8ce2f9bfbe41f55 Author: huxihx <huxi...@hotmail.com> Date: 2017-08-17T02:44:23Z Added newly-created fields for detailed views. commit c51781586646664bb9514d8ab03aa974f9e6a942 Author: huxihx <huxi...@hotmail.com> Date: 2017-08-21T01:18:24Z 1. Added parameter name when invoking testDetailedHeaderMatchBody; 2. Removed useless initialization for commit 9adda74004c531894a31b7653529b32336682316 Author: huxihx <huxi...@hotmail.com> Date: 2017-09-06T02:41:42Z added a field that tracks periodic join time. ---- ---