kafka git commit: KAFKA-2645: Document potentially breaking changes in the release note…

Repository: kafka Updated Branches: refs/heads/trunk e6f9b9e47 -> fc4ef4791 KAFKA-2645: Document potentially breaking changes in the release note… …s for 0.9.0 Author: Grant Henke Reviewers: Gwen Shapira, Guozhang Wang Closes #337 from granthenke/docs Project:

kafka git commit: KAFKA-2452: Add new consumer option to mirror maker.

Repository: kafka Updated Branches: refs/heads/trunk 2e4aed707 -> 2fd645ac2 KAFKA-2452: Add new consumer option to mirror maker. Author: Jiangjie Qin Reviewers: Ben Stopford, Guozhang Wang Closes #266 from becketqin/KAFKA-2452 Project:

kafka git commit: KAFKA-2516: Rename o.a.k.client.tools to o.a.k.tools

Repository: kafka Updated Branches: refs/heads/trunk fc4ef4791 -> 2e4aed707 KAFKA-2516: Rename o.a.k.client.tools to o.a.k.tools Author: Grant Henke Reviewers: Gwen Shapira, Ewen Cheslack-Postava Closes #310 from granthenke/tools-packaging Project:

kafka git commit: KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL

Repository: kafka Updated Branches: refs/heads/trunk 2fd645ac2 -> d21cb66e7 KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL Author: Ashish Singh Reviewers: Gwen Shapira, Ismael Juma Closes #175 from SinghAsDev/KAFKA-2447 Project:

kafka git commit: HOTFIX: call consumer.poll() even when no task is assigned

Repository: kafka Updated Branches: refs/heads/trunk 38a1b6055 -> af42c3789 HOTFIX: call consumer.poll() even when no task is assigned StreamThread should keep calling consumer.poll() even when no task is assigned. This is necessary to get a task. guozhangwang Author: Yasuhiro Matsuda

[2/2] kafka git commit: KAFKA-1888: rolling upgrade test

KAFKA-1888: rolling upgrade test ewencp gwenshap This needs some refactoring to avoid the duplicated code between replication test and upgrade test, but in shape for initial feedback. I'm interested in feedback on the added `KafkaConfig` class and `kafka_props` file. This addition makes it: -

[1/2] kafka git commit: KAFKA-1888: rolling upgrade test

Repository: kafka Updated Branches: refs/heads/trunk af42c3789 -> e6b343302 http://git-wip-us.apache.org/repos/asf/kafka/blob/e6b34330/tests/kafkatest/services/performance/jmx_mixin.py -- diff --git

kafka git commit: KAFKA-2677: ensure consumer sees coordinator disconnects

Repository: kafka Updated Branches: refs/heads/trunk e6b343302 -> 0b05d3b93 KAFKA-2677: ensure consumer sees coordinator disconnects Author: Jason Gustafson Reviewers: Ismael Juma, Guozhang Wang Closes #349 from hachikuji/KAFKA-2677 Project:

kafka git commit: HOTFIX: correct sourceNodes for kstream.through()

Repository: kafka Updated Branches: refs/heads/trunk 0b05d3b93 -> 13c3e049f HOTFIX: correct sourceNodes for kstream.through() guozhangwang Author: Yasuhiro Matsuda Reviewers: Guozhang Wang Closes #374 from ymatsuda/fix_through_operator Project:

kafka git commit: KAFKA-2683: ensure wakeup exceptions raised to user

Repository: kafka Updated Branches: refs/heads/trunk 13c3e049f -> 1ac2640f8 KAFKA-2683: ensure wakeup exceptions raised to user Author: Jason Gustafson Reviewers: Ewen Cheslack-Postava, Guozhang Wang Closes #366 from hachikuji/KAFKA-2683 Project:

kafka git commit: MINOR: Expose ReplicaManager gauges

Repository: kafka Updated Branches: refs/heads/trunk 1ac2640f8 -> 7a36d3647 MINOR: Expose ReplicaManager gauges There are several gauges in core that are registered but cannot be accessed programmatically. For example, gauges "LeaderCount", "PartitionCount", "UnderReplicatedParittions" are