[GitHub] kafka pull request #2375: Kafka 4060 remove zk client dependency in kafka st...
Github user hjafarpour closed the pull request at: https://github.com/apache/kafka/pull/2375 --- 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 #2389: Kafka 4060 remove zk client dependency in kafka st...
GitHub user hjafarpour opened a pull request: https://github.com/apache/kafka/pull/2389 Kafka 4060 remove zk client dependency in kafka streams followup re-branched from trunk Re-branched the trunk and applied the changes to the new branch to simplify commit log. 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-followup-from-trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2389.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 #2389 commit 8b8752e4e14e62ece344b8ba4addf41f63ac264e Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2017-01-17T22:23:06Z Rebranched the trunk and applied the changes to the new branch to simplify the commit log.. --- 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 #2377: Kafka 4060 docs update
GitHub user hjafarpour opened a pull request: https://github.com/apache/kafka/pull/2377 Kafka 4060 docs update Updated the docs with changes in KAFKA-4060. You can merge this pull request into a Git repository by running: $ git pull https://github.com/hjafarpour/kafka KAFKA-4060-docs-update Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2377.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 #2377 commit db0405c6994123417441ac328d2f9e7f96b8e851 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-20T00:10:54Z Removed Zookeeper dependency from Kafka Streams. Added two test for creating and deleting topics. They work in IDE but fail while build. Removing the new tests for now. commit 69b8baf766a0ed70de8782938cf6157fa6b01794 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-20T17:52:53Z Made changes according to the review feedback. commit f8952a287a7fec0d3a51db36c003a3d599491309 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-22T16:19:07Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit cb6891fe839cf6ca7ba46ca42437344764cf009e Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-22T17:13:01Z Made more changes based on review feedback. commit 393b909158aadada58a796402e8b6f03c0077ef9 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-23T17:34:46Z Applied review feedback. commit c19f0df4632eb2b2b9529aea0be3ed9173002b63 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-28T19:35:17Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 96264d47643b04d53293b86f3ffd718fbb688609 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-28T22:15:06Z Made changes based on Guozhang's comments. commit 4f7bfd6cc4147803d90168793f498f8a1b81f18b Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-29T22:08:39Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 5e386f0fe3c109dfea95b392569adbe8f32018a0 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T00:22:15Z Disabled auto topic generation for EmbeddedKafkaCluster. Removed polling in StreamPartitionAssignor. commit eb3ec2947ad9799ed35048faafd4bf35106f880a Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T18:49:42Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit f44a9853cbd38f9c10a0b15bc2297d8a242fce3f Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T20:22:04Z Now deleting and re creating existing topic with different number of partitions. commit 3d9dba21f0c39104f5e807a50f3fdb5956eda1bf Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T22:09:51Z Fixed some issues in tests. commit 5b0be7aa1a2b1d26ae453aab78fb4989c9145411 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T18:41:42Z Sending topic management request in batch. commit 8e064f1863aa8095cfae3f11a6f85513c498e479 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:36:12Z added the missing class. commit 74ce5b9f9e4b78dee346e77ac52bc053b9cc36f6 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:45:43Z Merge branch 'KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new' of https://github.com/hjafarpour/kafka into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit c986b539ad26a2c124da60984d1cac4c2aab97dc Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:59:21Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 37079dd28a15a6d36632631227c9d718ca451745 Author: Hojjat Jafarpour <hoj...@hojjatjpoursmbp.attlocal.net> Date: 2016-10-10T03:09:33Z Fixed the issue with tests. commit 21b6907d457591ba0a242e548549d315b38e69f2 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-24T16:46:49Z Made minor changes based on Guozhang's feedback. commit 3ae6583576b25f8fce4a9f4fac3f4a33bd8f47b6 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-24T16:49:23Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 253784edc252d80d5ecb3eda8ef506657f659ba1 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-24T20:35:48Z
[GitHub] kafka pull request #2375: Kafka 4060 remove zk client dependency in kafka st...
GitHub user hjafarpour opened a pull request: https://github.com/apache/kafka/pull/2375 Kafka 4060 remove zk client dependency in kafka streams followup Updated the KAFKA-4060 code based on the new Admin client API. Also we won't delete internal topics anymore. 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-followup Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2375.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 #2375 commit db0405c6994123417441ac328d2f9e7f96b8e851 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-20T00:10:54Z Removed Zookeeper dependency from Kafka Streams. Added two test for creating and deleting topics. They work in IDE but fail while build. Removing the new tests for now. commit 69b8baf766a0ed70de8782938cf6157fa6b01794 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-20T17:52:53Z Made changes according to the review feedback. commit f8952a287a7fec0d3a51db36c003a3d599491309 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-22T16:19:07Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit cb6891fe839cf6ca7ba46ca42437344764cf009e Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-22T17:13:01Z Made more changes based on review feedback. commit 393b909158aadada58a796402e8b6f03c0077ef9 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-23T17:34:46Z Applied review feedback. commit c19f0df4632eb2b2b9529aea0be3ed9173002b63 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-28T19:35:17Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 96264d47643b04d53293b86f3ffd718fbb688609 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-28T22:15:06Z Made changes based on Guozhang's comments. commit 4f7bfd6cc4147803d90168793f498f8a1b81f18b Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-29T22:08:39Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 5e386f0fe3c109dfea95b392569adbe8f32018a0 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T00:22:15Z Disabled auto topic generation for EmbeddedKafkaCluster. Removed polling in StreamPartitionAssignor. commit eb3ec2947ad9799ed35048faafd4bf35106f880a Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T18:49:42Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit f44a9853cbd38f9c10a0b15bc2297d8a242fce3f Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T20:22:04Z Now deleting and re creating existing topic with different number of partitions. commit 3d9dba21f0c39104f5e807a50f3fdb5956eda1bf Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-30T22:09:51Z Fixed some issues in tests. commit 5b0be7aa1a2b1d26ae453aab78fb4989c9145411 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T18:41:42Z Sending topic management request in batch. commit 8e064f1863aa8095cfae3f11a6f85513c498e479 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:36:12Z added the missing class. commit 74ce5b9f9e4b78dee346e77ac52bc053b9cc36f6 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:45:43Z Merge branch 'KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new' of https://github.com/hjafarpour/kafka into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit c986b539ad26a2c124da60984d1cac4c2aab97dc Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-07T21:59:21Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams-new commit 37079dd28a15a6d36632631227c9d718ca451745 Author: Hojjat Jafarpour <hoj...@hojjatjpoursmbp.attlocal.net> Date: 2016-10-10T03:09:33Z Fixed the issue with tests. commit 21b6907d457591ba0a242e548549d315b38e69f2 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-24T16:46:49Z Made minor changes based on Guozhang's feedback. commit 3ae6583576b25f8fce4a9f4fac3f4a33bd8f47b6 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-10-24T16:49:23Z Merge branch 'trunk' into KAFKA-4060-Remove-ZkClient-dependency-in-Kafka-Streams
[GitHub] kafka pull request #1884: KAFKA-4060: Remove zk client dependency in kafka s...
GitHub user hjafarpour opened a pull request: https://github.com/apache/kafka/pull/1884 KAFKA-4060: Remove zk client dependency in kafka streams @dguy This is a new PR for KAFKA-4060. 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-new Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1884.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 #1884 commit db0405c6994123417441ac328d2f9e7f96b8e851 Author: Hojjat Jafarpour <hojjat@hojjat-jafarpours-mbp.local> Date: 2016-09-20T00:10:54Z Removed Zookeeper dependency from Kafka Streams. Added two test for creating and deleting topics. They work in IDE but fail while build. Removing the new tests for now. --- 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...
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...
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. ---
