Thanks Patrick, I looked at the KIP and it looks good to me overall. I think we need to double check whether the record metadata reflect the "last processed record" or the "currently processed record" where the latter may not have been completely processed. In `ProcessorContext#recordMetadata` it returns the latter, but that may not be the preferred case if you want to build the consistency reasoning on top of.
Otherwise, LGTM. Guozhang On Wed, Nov 3, 2021 at 1:44 PM Patrick Stuedi <pstu...@confluent.io.invalid> wrote: > Hi everyone, > > I would like to start the discussion for KIP-791: Add Record Metadata to > State Store Context. > > The KIP can be found here: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-791:+Add+Record+Metadata+to+State+Store+Context > > Any feedback will be highly appreciated. > > Many thanks, > Patrick > -- -- Guozhang
