kafka git commit: KAFKA-4574; Ignore test_zk_security_upgrade until KIP-101 lands

2017-03-28 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk a0b8e435c -> 4ce65d65d KAFKA-4574; Ignore test_zk_security_upgrade until KIP-101 lands The transient failures make it harder to spot real failures and we can live without what is being tested (adding security to ZK via a rolling upgrade) u

kafka git commit: MINOR: Support streaming decompression of fetched records for new format

2017-03-28 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk edb372dca -> a0b8e435c MINOR: Support streaming decompression of fetched records for new format Author: Jason Gustafson Reviewers: Apurva Mehta , Guozhang Wang Closes #2738 from hachikuji/streaming-compressed-iterator Project: http://

kafka git commit: KAFKA-4959; Remove controller concurrent access to non-threadsafe NetworkClient, Selector, and SSLEngine

2017-03-28 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.10.2 1e4cab761 -> 2397269c4 KAFKA-4959; Remove controller concurrent access to non-threadsafe NetworkClient, Selector, and SSLEngine This brought down a cluster by causing continuous controller moves. ZkClient's ZkEventThread and a RequestSend

kafka git commit: KAFKA-4959; Remove controller concurrent access to non-threadsafe NetworkClient, Selector, and SSLEngine

2017-03-28 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 23a0f0986 -> edb372dca KAFKA-4959; Remove controller concurrent access to non-threadsafe NetworkClient, Selector, and SSLEngine This brought down a cluster by causing continuous controller moves. ZkClient's ZkEventThread and a RequestSendT

kafka git commit: Minor: Remove the accidentally checked in file which broke checkStyle.

2017-03-28 Thread jqin
Repository: kafka Updated Branches: refs/heads/trunk 8b05ad406 -> 23a0f0986 Minor: Remove the accidentally checked in file which broke checkStyle. Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/23a0f098 Tree: http://git-w

[2/3] kafka git commit: KAFKA-4586; Add purgeDataBefore() API (KIP-107)

2017-03-28 Thread jqin
http://git-wip-us.apache.org/repos/asf/kafka/blob/8b05ad40/core/src/main/scala/kafka/cluster/Partition.scala -- diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala ind

[3/3] kafka git commit: KAFKA-4586; Add purgeDataBefore() API (KIP-107)

2017-03-28 Thread jqin
KAFKA-4586; Add purgeDataBefore() API (KIP-107) Author: Dong Lin Reviewers: Jun Rao , Ismael Juma , Jiangjie Qin Closes #2476 from lindong28/KAFKA-4586 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8b05ad40 Tree: http:

[1/3] kafka git commit: KAFKA-4586; Add purgeDataBefore() API (KIP-107)

2017-03-28 Thread jqin
Repository: kafka Updated Branches: refs/heads/trunk f3f9a9eaf -> 8b05ad406 http://git-wip-us.apache.org/repos/asf/kafka/blob/8b05ad40/core/src/test/scala/integration/kafka/api/AdminClientTest.scala -- diff --git a/core/src/tes