GitHub user hjafarpour opened a pull request:
https://github.com/apache/kafka/pull/1799
Kafka 4060 remove zk client dependency in kafka streams
Removed Zookeeper client from the Kafka Streams. The internal topic manager
now will use Kafka Client to create/delete internal topics.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hjafarpour/kafka
KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1799.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1799
----
commit ed3f003ee1851c47df74167ca13874e8e2bd846d
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-23T21:24:34Z
Removed the ZooKeeper dependency from Kafka Streams and instead use the
KafkaClient to create imtermediate topics. We will check if a topic exits
already, if it does we delete it. Then we create the topic.
commit 5fbded64c9230441c8d9c5936fdfee75a23c312d
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-24T16:23:59Z
Code style fixes.
commit 9f8fae9135366ef80a61fc049497ad045e76b573
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-24T19:56:18Z
Removed ZOOKEEPER_CONNECT_CONFIG from StreamConfig along with it's uses.
commit 25a35d8f7f43d42065d59fadafd85acf6b57e4a2
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-24T21:16:24Z
Updated the unittest for InternalTopicIntegration to test the new behaviour
using the KafkaClient.
commit 10fb87c1bb04a5acf1d8c79dd2afe8a359b0be82
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-29T18:13:30Z
Merge remote-tracking branch 'upstream/trunk' into
KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams
commit dfd3e4be313c2a40c802aaef9b7dba03cd6c3682
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-29T20:38:04Z
Added StreamsKafkaClient to wrap the kafka client so we can have a proper
close. Tests are passing now.
commit 2cde963850c62c54e81b6772bb708934e107f62b
Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local>
Date: 2016-08-29T20:58:42Z
Fixed the word count example changes.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
