kafka git commit: KAFKA-4749; Fix join-time-max and sync-time-max MeasurableStat type

2017-02-08 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 8bd8751aa -> 6c1478d19 KAFKA-4749; Fix join-time-max and sync-time-max MeasurableStat type GroupCoordinatorMetrics currently sets up join-time-max and sync-time-max incorrectly as a "new Avg()" MeasurableStat instead of "new Max()" Author:

kafka git commit: MINOR: changes to the production broker configuration docs.

2017-02-08 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.10.2 b75d37a2a -> 39f1a7d8c MINOR: changes to the production broker configuration docs. Author: Alex Loddengaard Reviewers: Jun Rao Closes #2519 from alexlod/production-config-docs (cherry picked from commit 8bd8751aa776990d1847e4d6ab187a0a

kafka git commit: MINOR: changes to the production broker configuration docs.

2017-02-08 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 13a82b48c -> 8bd8751aa MINOR: changes to the production broker configuration docs. Author: Alex Loddengaard Reviewers: Jun Rao Closes #2519 from alexlod/production-config-docs Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

kafka git commit: KAFKA-4702: Parametrize streams benchmarks to run at scale

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk c7c113af6 -> 13a82b48c KAFKA-4702: Parametrize streams benchmarks to run at scale Author: Eno Thereska Author: Eno Thereska Author: Ubuntu Reviewers: Matthias J. Sax, Guozhang Wang Closes #2478 from enothereska/minor-benchmark-args Pr

kafka git commit: MINOR: Add logging when commitSync fails in StreamTask

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk e7c869e65 -> c7c113af6 MINOR: Add logging when commitSync fails in StreamTask When `consumer.commitSync` fails in `StreamTask`, the `CommitFailedException` bubbles up to [here](https://github.com/apache/kafka/blob/trunk/streams/src/main/ja

kafka git commit: HOTFIX: renamed test so it is picked up by ducktape

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 bec105d48 -> b75d37a2a HOTFIX: renamed test so it is picked up by ducktape Author: Eno Thereska Reviewers: Matthias J. Sax, Guozhang Wang Closes #2517 from enothereska/hotfix-broker-test (cherry picked from commit e7c869e65d25dcf2d0a8f9

kafka git commit: HOTFIX: renamed test so it is picked up by ducktape

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk b62170370 -> e7c869e65 HOTFIX: renamed test so it is picked up by ducktape Author: Eno Thereska Reviewers: Matthias J. Sax, Guozhang Wang Closes #2517 from enothereska/hotfix-broker-test Project: http://git-wip-us.apache.org/repos/asf/k

kafka git commit: KAFKA-4648: Improve test coverage StreamTask

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk effa19c04 -> b62170370 KAFKA-4648: Improve test coverage StreamTask Provide test coverage for exception paths in: `schedule()`, `closeTopology()`, and `punctuate()` Author: Damian Guy Reviewers: Matthias J. Sax, Guozhang Wang Closes #24

kafka git commit: KAFKA-4741; Fix potential buffer leak in RecordAccumulator in case of exception

2017-02-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 2e662a061 -> effa19c04 KAFKA-4741; Fix potential buffer leak in RecordAccumulator in case of exception Author: Satish Duggana Reviewers: Dong Lin , Ismael Juma Closes #2509 from satishd/buffer-cleanup Project: http://git-wip-us.apache.

kafka git commit: KAFKA-4733: Improve Streams Reset Tool console output

2017-02-08 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 7f6bf5d44 -> 2e662a061 KAFKA-4733: Improve Streams Reset Tool console output Added general explanation of the tool and what it does. Also added few details to the arguments. Author: Gwen Shapira Reviewers: Matthias J. Sax, Michael G. Nol