Thanks John, I've been looking forward to this for a while now. It was pretty horrifying to learn how present-day IQ works (or rather, doesn't work) with custom state stores :/
One minor cosmetic point, In the InteractiveQueryRequest class, the # getPartitions method has a return type of Set<Integer>, but the javadocs refer to Optional. Not sure which is intended for this API, but if is supposed to be the return type, do you perhaps mean for it to be Optional.ofEmpty() and Optional.of(non-empty set) rather than Optional.of(empty set) and Optional.of(non-empty set) ? On Thu, Nov 11, 2021 at 12:03 PM John Roesler <vvcep...@apache.org> wrote: > Hello again, all, > > Just bumping this discussion on a new, more flexible > Interactive Query API in Kafka Streams. > > If there are no concerns, I'll go ahead and call a vote on > Monday. > > Thanks! > -John > > On Tue, 2021-11-09 at 17:37 -0600, John Roesler wrote: > > Hello all, > > > > I'd like to start the discussion for KIP-796, which proposes > > a revamp of the Interactive Query APIs in Kafka Streams. > > > > The proposal is here: > > https://cwiki.apache.org/confluence/x/34xnCw > > > > I look forward to your feedback! > > > > Thank you, > > -John > > > > >
