kafka git commit: MINOR: close iterator on doc example

2017-09-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 9b85cf9ed -> b041c8d87 MINOR: close iterator on doc example The iterator interface usage has some examples missing explicit close operation after usage. We should remind the user to do so because un-closed iterator will leave the

kafka git commit: MINOR: Log encountered exception during rebalance

2017-09-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 212bce6e3 -> 3f155eaa2 MINOR: Log encountered exception during rebalance Some other minor changes: 1. Do not throw the exception form callback as it would only be swallowed by consumer coordinator; remembering it and re-throw in the next

kafka git commit: MINOR: fix typos on web doc's upgrade guide

2017-09-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 23d01c805 -> 212bce6e3 MINOR: fix typos on web doc's upgrade guide Author: Matthias J. Sax Reviewers: Guozhang Wang Closes #3804 from mjsax/hotfix Project:

kafka-site git commit: Remove .DS_Store

2017-09-06 Thread ewencp
Repository: kafka-site Updated Branches: refs/heads/asf-site 5885aded0 -> 8c85a0e4f Remove .DS_Store Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/8c85a0e4 Tree:

kafka-site git commit: Adding portoseguro, micronauticsresearch & cj logos to powered by page

2017-09-06 Thread ewencp
Repository: kafka-site Updated Branches: refs/heads/asf-site 1100aae09 -> 5885aded0 Adding portoseguro, micronauticsresearch & cj logos to powered by page Author: Manjula Kumar Reviewers: Ewen Cheslack-Postava Closes #74 from manjuapu/asf-site

kafka-site git commit: Fix HTML markup

2017-09-06 Thread ewencp
Repository: kafka-site Updated Branches: refs/heads/asf-site b99a8350b -> 1100aae09 Fix HTML markup Author: Matthias J. Sax Reviewers: Ewen Cheslack-Postava Closes #75 from jsax/hotfix Project:

kafka git commit: KAFKA-5726; KafkaConsumer.subscribe() overload that takes just Pattern

2017-09-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 510257646 -> 23d01c805 KAFKA-5726; KafkaConsumer.subscribe() overload that takes just Pattern - changed the interface & implementations - updated tests to use the new method where applicable Author: Attila Kreiner

kafka git commit: KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush

2017-09-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 fc3eeb004 -> d93bd1aff KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush Author: oleg Reviewers: Randall Hauch , Jason Gustafson Closes #3702 from

kafka git commit: KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush

2017-09-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 45394d52c -> 510257646 KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush Author: oleg Reviewers: Randall Hauch , Jason Gustafson Closes #3702 from

kafka git commit: KAFKA-5819; Add Joined class and relevant KStream join overloads

2017-09-06 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk b687c0680 -> 45394d52c KAFKA-5819; Add Joined class and relevant KStream join overloads Add the `Joined` class and the overloads to `KStream` that use it. Deprecate existing methods that have `Serde` params Author: Damian Guy

kafka git commit: KAFKA-5817; Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey

2017-09-06 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 2fb5664bf -> b687c0680 KAFKA-5817; Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey Part of KIP-182 - Add the `Serialized` class - implement overloads of `KStream#groupByKey` and KStream#groupBy` - deprecate