Thanks for the KIP, Sagar! At first glance, this seems like a very useful feature.
A common pain point in Streams is when upstream producers don't send regular updates and stream time cannot advance. This causes stream-time-driven operations to appear to hang, like time windows not closing, suppressions not firing, etc. >From your KIP, I have a good idea of how the feature would be integrated into >connect, and it sounds good to me. I don't quite see how downstream clients, >such as a downstream Streams or Flink application, or users of the Consumer >would make use of this feature. Could you add some examples of that nature? Thank you, -John On Fri, Mar 24, 2023, at 05:23, Sagar wrote: > Hi All, > > Bumping the thread again. > > Sagar. > > > On Fri, Mar 10, 2023 at 4:42 PM Sagar <sagarmeansoc...@gmail.com> wrote: > >> Hi All, >> >> Bumping this discussion thread again. >> >> Thanks! >> Sagar. >> >> On Thu, Mar 2, 2023 at 3:44 PM Sagar <sagarmeansoc...@gmail.com> wrote: >> >>> Hi All, >>> >>> I wanted to create a discussion thread for KIP-910: >>> >>> >>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-910%3A+Update+Source+offsets+for+Source+Connectors+without+producing+records >>> >>> Thanks! >>> Sagar. >>> >>
