[GitHub] kafka pull request #1799: Kafka 4060 remove zk client dependency in kafka st...

[hjafarpour]

Github user hjafarpour closed the pull request at:

https://github.com/apache/kafka/pull/1799


---
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.
---

[GitHub] kafka pull request #1799: Kafka 4060 remove zk client dependency in kafka st...

[hjafarpour]

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 
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 
Date:   2016-08-24T16:23:59Z

Code style fixes.

commit 9f8fae9135366ef80a61fc049497ad045e76b573
Author: Hojjat Jafarpour 
Date:   2016-08-24T19:56:18Z

Removed ZOOKEEPER_CONNECT_CONFIG from StreamConfig along with it's uses.

commit 25a35d8f7f43d42065d59fadafd85acf6b57e4a2
Author: Hojjat Jafarpour 
Date:   2016-08-24T21:16:24Z

Updated the unittest for InternalTopicIntegration to test the new behaviour 
using the KafkaClient.

commit 10fb87c1bb04a5acf1d8c79dd2afe8a359b0be82
Author: Hojjat Jafarpour 
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 
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 
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.
---