Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Sorry for the late reply, thanks for the review. > About `StateStoreMigratedException`: > > Why is it only thrown if the state is REBALANCING? A store might be > migrated during a rebalance, and Kafka Streams might resume back to > RUNNING state and afterward somebody tries to use an old store ha

Re: [VOTE] KIP-523 Add KStream#toTable to the Streams DSL

This thread has been open for more than 72 hours. So far there are 2 binding and 1 non-binding votes, looking to conclude this quickly!! Best, Aishwarya On Mon, Oct 28, 2019 at 5:00 PM John Roesler wrote: > Thanks, Aishwarya! > > I'm +1 (non-binding) > > -John > > On Mon, Oct 28, 2019 at 11:58

Re: [VOTE] KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

Hello All, Calling this vote to a close with +3 binding (Matthias J. Sax, Guozhang Wang, Bill Bejeck) and +1 non-binding (Bruno Cadonna). Thank You all for the discussion and votes. Will be opening a PR for this soon With Best Regards, Rabi Kumar K C On Fri, Oct 25, 2019 at 10:47 AM RABI K.C.

Build failed in Jenkins: kafka-trunk-jdk8 #4017

See Changes: [wangguoz] HOTFIX: Remove from restoringByPartition once restored (#7631) -- [...truncated 5.54 MB...] org.apache.kafka.streams.scala.kstream.KTableTest > n