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
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
Reviewers: Guozhang Wang
Closes #2385 from dguy/minor-remove-unused-param
commit 621dff22e79dc64b9a8748186dd985774044f91a
Author: Rajini Sivaram
Date: 2017-01-17T11:16:29Z
KAFKA-4363; Documentation for sasl.jaas.config property
Author: Rajini Sivaram
Reviewers: Ismael Juma
Closes #2316 from rajinisivaram/KAFKA-4363
commit e3f4cdd0e249f78a7f4e8f064533bcd15eb11cbf
Author: Rajini Sivaram
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
Reviewers: Ewen Cheslack-Postava , Ismael Juma
Closes #2355 from rajinisivaram/KAFKA-4590
commit 2b19ad9d8c47fb0f78a6e90d2f5711df6110bf1f
Author: Rajini Sivaram
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
Reviewers: Ewen Cheslack-Postava , Ismael Juma
Closes #2323 from rajinisivaram/KAFKA-4580
(cherry picked from commit 3f6c4f63c9c17424cf717ca76c74554bcf3b2e9a)
Signed-off-by: Ismael Juma
commit 60d759a227087079e6fd270c68fd9e38441cb34a
Author: Jason Gustafson
Date: 2017-01-17T18:42:05Z
MINOR: Some cleanups and additional testing for KIP-88
Author: Jason Gustafson
Reviewers: Vahid Hashemian , Ismael Juma
Closes #2383 from hachikuji/minor-cleanup-kip-88
commit c9b9acf6a8b542c2d0d825c17a4a20cf3fa5
Author: Damian Guy
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
Reviewers: Matthias J. Sax, Guozhang Wang
Closes #2371 from dguy/integration-test-fix
(cherry picked from commit 825f225bc5706b16af8ec44ca47ee1452c11e6f3)
Signed-off-by: Guozhang Wang
commit 6f72a5a53c444278187fa6be58031168bcaffb26
Author: Damian Guy
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
Reviewers: Guozhang Wang
Closes #2360 from dguy/state-store-refactor
(cherry picked from commit 73b7ae0019d387407375f3865e263225c986a6ce)
Signed-off-by: Guozhang Wang
commit eb62e5695506ae13bd37102c3c08e8a067eca0c8
Author: Ismael Juma
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 AutoCloseable