[GitHub] kafka pull request #2631: KAFKA:4706 - Unify StreamsKafkaClient instances
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2631 KAFKA:4706 - Unify StreamsKafkaClient instances KAFKA:4706 - Unify StreamsKafkaClient instances You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4706 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2631.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 #2631 commit 906eeaeb3b8711ecd22cd834f554291b702781f3 Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-03T02:06:37Z KAFKA:4706 - Unify StreamsKafkaClient instances --- 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 #2481: Kafka 4706 :Unify StreamsKafkaClient instances
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2481 --- 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 #2616: KAFKA:4738 - Remove generic type of class ClientSt...
GitHub user sharad-develop reopened a pull request: https://github.com/apache/kafka/pull/2616 KAFKA:4738 - Remove generic type of class ClientState Remove generic type of class ClientState and generic T inTaskAssignor. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4738 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2616.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 #2616 commit 3e06cc8dcdef3afaaed71576d66dc14f61da6d7a Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-01T00:29:10Z KAFKA:4738 - Remove generic type of class ClientState --- 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 #2625: KAFKA:4623- Change default unclean.leader.election...
GitHub user sharad-develop reopened a pull request: https://github.com/apache/kafka/pull/2625 KAFKA:4623- Change default unclean.leader.election.enabled from True to False KAFKA:4623- Change default unclean.leader.election.enabled from True to False You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4623 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2625.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 #2625 commit 0aa2549ed5973cb724b4d5a16ee9bc2fdf16f523 Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-01T20:03:02Z KAFKA:4623- Change default unclean.leader.election.enabled from True to False --- 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 #2470: Kafka-4711 :Change Default unclean.leader.election...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2470 --- 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 #2625: KAFKA:4623- Change default unclean.leader.election...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2625 --- 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 #2625: KAFKA:4623- Change default unclean.leader.election...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2625 KAFKA:4623- Change default unclean.leader.election.enabled from True to False KAFKA:4623- Change default unclean.leader.election.enabled from True to False You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4623 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2625.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 #2625 commit 0aa2549ed5973cb724b4d5a16ee9bc2fdf16f523 Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-01T20:03:02Z KAFKA:4623- Change default unclean.leader.election.enabled from True to False --- 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 #2616: KAFKA:4738 - Remove generic type of class ClientSt...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2616 --- 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 #2617: KAFKA:4722 - Add application.id to StreamThread na...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2617 KAFKA:4722 - Add application.id to StreamThread name Add application.id to StreamThread name You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4722 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2617.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 #2617 commit 5132da450bdf407f1202d83ed687c7bc31191397 Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-01T01:41:06Z KAFKA:4722 - Add application.id to StreamThread name --- 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 #2487: Kafka-4722 : Add application.id to StreamThread na...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2487 --- 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 #2616: KAFKA:4738 - Remove generic type of class ClientSt...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2616 KAFKA:4738 - Remove generic type of class ClientState Remove generic type of class ClientState and generic T inTaskAssignor. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4738 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2616.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 #2616 commit 3e06cc8dcdef3afaaed71576d66dc14f61da6d7a Author: sharad.develop <sharad.deve...@gmail.com> Date: 2017-03-01T00:29:10Z KAFKA:4738 - Remove generic type of class ClientState --- 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 #2605: Kafka 4738:Remove generic type of class ClientStat...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2605 --- 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 #2487: Kafka-4722 : Add application.id to StreamThread na...
GitHub user sharad-develop reopened a pull request: https://github.com/apache/kafka/pull/2487 Kafka-4722 : Add application.id to StreamThread name Kafka-4722 : Add application.id to StreamThread name You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4722 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2487.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 #2487 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z KAFKA-4591; Create Topic Policy follow-up 1. Added javadoc to public classes 2. Removed `s` from config name for consistency with int
[GitHub] kafka pull request #2487: Kafka-4722 : Add application.id to StreamThread na...
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2487 --- 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 #2605: Kafka 4738:Remove generic type of class ClientStat...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2605 Kafka 4738:Remove generic type of class ClientState Remove generic type of class ClientState. Also removed Generic type from TaskAssignor as it referred to same generic type of ClientState You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4738 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2605.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 #2605 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z KAFKA-4591; Create Topic Policy follow-up 1. Added javadoc t
[GitHub] kafka pull request #2487: Kafka-4722 : Add application.id to StreamThread na...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2487 Kafka-4722 : Add application.id to StreamThread name Kafka-4722 : Add application.id to StreamThread name You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4722 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2487.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 #2487 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z KAFKA-4591; Create Topic Policy follow-up 1. Added javadoc to public classes 2. Removed `s` from config name for consistency with int
[GitHub] kafka pull request #2481: Kafka 4706 :Unify StreamsKafkaClient instances
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2481 Kafka 4706 :Unify StreamsKafkaClient instances Kafka 4706 :Unify StreamsKafkaClient instances You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4706 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2481.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 #2481 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z KAFKA-4591; Create Topic Policy follow-up 1. Added javadoc to public classes 2. Removed `s` from config name for consistency with interface name
[GitHub] kafka pull request #2470: Kafka-4711 :Change Default unclean.leader.election...
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2470 Kafka-4711 :Change Default unclean.leader.election.enabled from True to False (KIP-106) Kafka-4711 :Change Default unclean.leader.election.enabled from True to False (KIP-106) KAFKA-4623 :Change Default unclean.leader.election.enabled from True to False You can merge this pull request into a Git repository by running: $ git pull https://github.com/sharad-develop/kafka KAFKA-4711 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2470.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 #2470 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z
[GitHub] kafka pull request #2463: KAFKA-4706
Github user sharad-develop closed the pull request at: https://github.com/apache/kafka/pull/2463 --- 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 #2463: 4706
GitHub user sharad-develop opened a pull request: https://github.com/apache/kafka/pull/2463 4706 4706 - Unify StreamsKafkaClient instances You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/kafka 0.10.2 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2463.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 #2463 commit 7946b2f35c0e3811ba7d706fc9c761d73ece47bb Author: Damian Guy <damian@gmail.com> Date: 2017-01-16T19:40:47Z MINOR: Remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2385 from dguy/minor-remove-unused-param commit 621dff22e79dc64b9a8748186dd985774044f91a Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T11:16:29Z KAFKA-4363; Documentation for sasl.jaas.config property Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2316 from rajinisivaram/KAFKA-4363 commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T12:55:07Z KAFKA-4590; SASL/SCRAM system tests Runs sanity test and one replication test using SASL/SCRAM. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2355 from rajinisivaram/KAFKA-4590 commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f Author: Rajini Sivaram <rajinisiva...@googlemail.com> Date: 2017-01-17T18:42:55Z KAFKA-4580; Use sasl.jaas.config for some system tests Switched console_consumer, verifiable_consumer and verifiable_producer to use new sasl.jaas_config property instead of static JAAS configuration file when used with SASL_PLAINTEXT. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Ewen Cheslack-Postava <e...@confluent.io>, Ismael Juma <ism...@juma.me.uk> Closes #2323 from rajinisivaram/KAFKA-4580 (cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a) Signed-off-by: Ismael Juma <ism...@juma.me.uk> commit 60d759a227087079e6fd270c68fd9e38441cb34a Author: Jason Gustafson <ja...@confluent.io> Date: 2017-01-17T18:42:05Z MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson <ja...@confluent.io> Reviewers: Vahid Hashemian <vahidhashem...@us.ibm.com>, Ismael Juma <ism...@juma.me.uk> Closes #2383 from hachikuji/minor-cleanup-kip-88 commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T20:33:11Z KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable After debugging this i can see the times that it fails there is a race between when the topic is actually created/ready on the broker and when the assignment happens. When it fails `StreamPartitionAssignor.assign(..)` gets called with a `Cluster` with no topics. Hence the test hangs as no tasks get assigned. To fix this I added a `waitForTopics` method to `EmbeddedKafkaCluster`. This will wait until the topics have been created. Author: Damian Guy <damian@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2371 from dguy/integration-test-fix (cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit 6f72a5a53c444278187fa6be58031168bcaffb26 Author: Damian Guy <damian@gmail.com> Date: 2017-01-17T22:13:46Z KAFKA-3452 Follow-up: Refactoring StateStore hierarchies This is a follow up of https://github.com/apache/kafka/pull/2166 - refactoring the store hierarchies as requested Author: Damian Guy <damian@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2360 from dguy/state-store-refactor (cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce) Signed-off-by: Guozhang Wang <wangg...@gmail.com> commit eb62e5695506ae13bd37102c3c08e8a067eca0c8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2017-01-18T02:43:10Z KAFKA-4591; Create Topic Policy follow-up 1. Added javadoc to public classes 2. Removed `s` from config name for consistency with interface name 3. The policy interface now implements Configurable and Aut
