It wasn't quite clear to me how the user program interacts with the discovery API, especially on the user supplied listener part, how does the user program supply that listener to KafkaStreams and how does KafkaStreams know which port the user listener is running, maybe a more complete end-to-end example including the steps on registering the user listener and whether the user listener needs to be involved with task reassignment.
On Wed, Jul 6, 2016 at 9:13 PM, Guozhang Wang <wangg...@gmail.com> wrote: > ＋1 > > On Wed, Jul 6, 2016 at 12:44 PM, Damian Guy <damian....@gmail.com> wrote: > > > Hi all, > > > > I'd like to initiate the voting process for KIP-67 > > < > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A+Queryable+state+for+Kafka+Streams > > > > > > > KAFKA-3909 <https://issues.apache.org/jira/browse/KAFKA-3909> is the top > > level JIRA for this effort. > > > > Initial PRs for Step 1 of the process are: > > Expose State Store Names <https://github.com/apache/kafka/pull/1526> and > > Query Local State Stores <https://github.com/apache/kafka/pull/1565> > > > > Thanks, > > Damian > > > > > > -- > -- Guozhang >
