GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1576
KAFKA-3914: Global discovery of state stores @guozhangwang @enothereska @mjsax @miguno please take a look. A few things that need to be clarified 1. I've added StreamsConfig.USER_ENDPOINT_CONFIG, but should we have separate configs for host and port or is this one config ok? 2. `HostState` in the KIP has a byte[] field - not sure why and what it would be populated with 3. I've changed the API to return `List<KafkaStreamsInstance>` as opposed to `Map<HostInfo, Set<TaskMetadata>>` as i find this far more intuitive to work with. You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka kafka-3914v2 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1576.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 #1576 ---- commit f22ca0e680063d42240d8ceebe140ecd9e3fab48 Author: Damian Guy <damian....@gmail.com> Date: 2016-06-29T07:40:11Z Connect stateStores to source topics. Add user endpoint config to StreamsConfig. Collect Map<HostState, Set<TopicPartition>> in StreamPartitionAssignor API for retrieving Map<HostState, TaskMetadata> commit 2030da06a22b4160760a2d29a7afd394bd29972b Author: Damian Guy <damian....@gmail.com> Date: 2016-06-30T09:09:50Z change api to use List and KafkaStreamsInstance rather than Map.. ---- --- 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. ---