kafka git commit: MINOR: Refactor partition lag metric for cleaner encapsulation

2017-01-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.10.2 6493e5d8d -> d8f9e18aa MINOR: Refactor partition lag metric for cleaner encapsulation Author: Jason Gustafson Reviewers: Jiangjie Qin , Guozhang Wang , Ismael Juma

kafka git commit: MINOR: Refactor partition lag metric for cleaner encapsulation

2017-01-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 51e745ef3 -> 135488352 MINOR: Refactor partition lag metric for cleaner encapsulation Author: Jason Gustafson Reviewers: Jiangjie Qin , Guozhang Wang , Ismael Juma

kafka git commit: MINOR: Fix typo in WordCountProcessorDemo

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 d54855a48 -> 6493e5d8d MINOR: Fix typo in WordCountProcessorDemo `bin-kafka-console-producer.sh` should be `bin/kafka-console-producer.sh`. Author: Will Marshall Reviewers: Guozhang Wang Closes

kafka git commit: MINOR: Fix typo in WordCountProcessorDemo

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 9a7032720 -> 51e745ef3 MINOR: Fix typo in WordCountProcessorDemo `bin-kafka-console-producer.sh` should be `bin/kafka-console-producer.sh`. Author: Will Marshall Reviewers: Guozhang Wang Closes

kafka git commit: MINOR: Clarify misleading comment in WordCount example

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 47154d804 -> d54855a48 MINOR: Clarify misleading comment in WordCount example Author: Gwen Shapira Reviewers: Matthias J. Sax, Guozhang Wang Closes #2400 from gwenshap/wordcount-comment (cherry picked from commit

kafka git commit: MINOR: Clarify misleading comment in WordCount example

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk e9426291a -> 9a7032720 MINOR: Clarify misleading comment in WordCount example Author: Gwen Shapira Reviewers: Matthias J. Sax, Guozhang Wang Closes #2400 from gwenshap/wordcount-comment Project:

kafka git commit: KAFKA-4684: add kafka-configs.bat for Windows boxes

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 e74a92463 -> 47154d804 KAFKA-4684: add kafka-configs.bat for Windows boxes Add kafka-configs.bat script for Windows. Author: huxi Reviewers: Guozhang Wang, Vahid Hashemian Closes #2419 from

kafka git commit: KAFKA-4684: add kafka-configs.bat for Windows boxes

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 8b3c6c0a1 -> e9426291a KAFKA-4684: add kafka-configs.bat for Windows boxes Add kafka-configs.bat script for Windows. Author: huxi Reviewers: Guozhang Wang, Vahid Hashemian Closes #2419 from

kafka git commit: KAFKA-4597; RecordMetadata should return log append time when appropriate

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 94c0da2b7 -> e74a92463 KAFKA-4597; RecordMetadata should return log append time when appropriate There is a slight change of behaviour: we now complete the `Future` returned from `send` before the callbacks are invoked. This seems OK and

kafka git commit: KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 1d2426683 -> 94c0da2b7 KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7 Author: Ismael Juma Reviewers: Jason Gustafson Closes #2434 from

kafka git commit: KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 0971e62e5 -> 23f695196 KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7 Author: Ismael Juma Reviewers: Jason Gustafson Closes #2434 from

kafka git commit: HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node throughput metrics, and also rename some other sensors

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 ec3975978 -> 1d2426683 HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node throughput metrics, and also rename some other sensors This is the HOTFIX PR for any issues detected with KIP-104 until code freeze. Note: do not

kafka git commit: HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node throughput metrics, and also rename some other sensors

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 2ca3e59bb -> 0971e62e5 HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node throughput metrics, and also rename some other sensors This is the HOTFIX PR for any issues detected with KIP-104 until code freeze. Note: do not merge

kafka git commit: KAFKA-3502: KStreamTestDriver needs to be closed after the test case

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk b22a4f078 -> 2ca3e59bb KAFKA-3502: KStreamTestDriver needs to be closed after the test case Found a few recently added unit tests did not close KStreamTestDriver after the test itself is closed; this can cause RocksDB virtual function

kafka git commit: KAFKA-3502: KStreamTestDriver needs to be closed after the test case

2017-01-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.10.2 b0742c202 -> ec3975978 KAFKA-3502: KStreamTestDriver needs to be closed after the test case Found a few recently added unit tests did not close KStreamTestDriver after the test itself is closed; this can cause RocksDB virtual function

kafka git commit: KAFKA-2000; Delete topic should also delete consumer offsets.

2017-01-25 Thread sriharsha
Repository: kafka Updated Branches: refs/heads/0.10.2 f0388d923 -> b0742c202 KAFKA-2000; Delete topic should also delete consumer offsets. Author: Manikumar Reddy O Reviewers: Jason Gustafson , Sriharsha Chintalapani

kafka git commit: KAFKA-2000; Delete topic should also delete consumer offsets.

2017-01-25 Thread sriharsha
Repository: kafka Updated Branches: refs/heads/trunk b8c3b7c96 -> b22a4f078 KAFKA-2000; Delete topic should also delete consumer offsets. Author: Manikumar Reddy O Reviewers: Jason Gustafson , Sriharsha Chintalapani

kafka git commit: KAFKA-4596; Throttled reassignment should support partial JSON file

2017-01-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.10.2 e0eefdd36 -> f0388d923 KAFKA-4596; Throttled reassignment should support partial JSON file Fixes a logic error in the Reassignment process which throws an exception if you don't rebalance all partitions. Author: Ben Stopford

kafka git commit: KAFKA-4596; Throttled reassignment should support partial JSON file

2017-01-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 448c1a411 -> b8c3b7c96 KAFKA-4596; Throttled reassignment should support partial JSON file Fixes a logic error in the Reassignment process which throws an exception if you don't rebalance all partitions. Author: Ben Stopford