kafka git commit: MINOR: fixed some JavaDoc typos

2017-02-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.2 588c5667f -> 7bb1d2a44 MINOR: fixed some JavaDoc typos Author: Matthias J. Sax Reviewers: Ewen Cheslack-Postava Closes #2497 from mjsax/hofixJavaDocs0102 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wi

kafka git commit: KAFKA-4735; Fix deadlock issue during MM shutdown

2017-02-06 Thread jqin
Repository: kafka Updated Branches: refs/heads/trunk 2c0055e62 -> 45d9fb3d5 KAFKA-4735; Fix deadlock issue during MM shutdown In https://issues.apache.org/jira/browse/KAFKA-4521 we fixed a potential message reorder bug in MM. However, the patch introduced another bug that can cause deadlock

kafka git commit: HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 82e75b960 -> 2c0055e62 HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils Removed readKeyValues() that give UNLIMITED_MESSAGES which will doom to exhaust all wait time, as all its callers actually do provide the expected numb

kafka git commit: MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant

2017-02-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.2 13a09557a -> 588c5667f MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant Author: Ewen Cheslack-Postava Reviewers: Matthias J. Sax , Guozhang Wang Closes #2508 from ewencp/minor-streams-compatibilit

kafka git commit: MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant

2017-02-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 48aec6ef1 -> 82e75b960 MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant Author: Ewen Cheslack-Postava Reviewers: Matthias J. Sax , Guozhang Wang Closes #2508 from ewencp/minor-streams-compatibility

kafka git commit: KAFKA-4441; Monitoring incorrect during topic creation and deletion

2017-02-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.10.2 f4276b7cf -> 13a09557a KAFKA-4441; Monitoring incorrect during topic creation and deletion OfflinePartitionsCount PreferredReplicaImbalanceCount metrics check for topic being deleted Added integration test which polls the metrics while top

kafka git commit: KAFKA-4441; Monitoring incorrect during topic creation and deletion

2017-02-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk b31a7a902 -> 48aec6ef1 KAFKA-4441; Monitoring incorrect during topic creation and deletion OfflinePartitionsCount PreferredReplicaImbalanceCount metrics check for topic being deleted Added integration test which polls the metrics while topi

kafka git commit: KAFKA-4728; KafkaConsumer#commitSync should copy its input

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 e321cd4f5 -> f4276b7cf KAFKA-4728; KafkaConsumer#commitSync should copy its input Author: Jan Lukavsky Reviewers: Jason Gustafson Closes #2491 from je-ik/KAFKA-4728 (cherry picked from commit b31a7a9022bfb645cb61e6fbc0b22829108b3a3f) S

kafka git commit: KAFKA-4728; KafkaConsumer#commitSync should copy its input

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 1f8a2ad2e -> b31a7a902 KAFKA-4728; KafkaConsumer#commitSync should copy its input Author: Jan Lukavsky Reviewers: Jason Gustafson Closes #2491 from je-ik/KAFKA-4728 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: htt

kafka git commit: KAFKA-4461: Added support to ProcessorTopologyTestDriver for internal topics

2017-02-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 7de22453b -> 1f8a2ad2e KAFKA-4461: Added support to ProcessorTopologyTestDriver for internal topics This resolves an issue in driving tests using the ProcessorTopologyTestDriver when `groupBy()` is invoked downstream of a processor that fla

kafka git commit: KAFKA-4724: Clean up of state directories can possibly remove stores that are about to be used by another thread

2017-02-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk d0932b028 -> 7de22453b KAFKA-4724: Clean up of state directories can possibly remove stores that are about to be used by another thread Delay the cleanup of state directories that are not locked and not owned by the current thread such tha