[GitHub] [kafka] avalsa commented on issue #8221: KAFKA-9561: update task input partitions after rebalance

[GitBox <gi...@apache.org>]

avalsa commented on issue #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-617208888


   > I saw that the stream time update codepath is missing, could we add it back? I was thinking about a simpler approach here: since we could not decrement the stream-time, no matter we are adding or removing partitions, we shall just iterate over all the result partitions and find the min partition time. If that min partition time is larger than current stream time, we advance it; otherwise we do nothing, WDYT? @guozhangwang @avalsa
   
   I think like it's in code: if we can skip update streamTime and it will not violate any requirements it's easiest what we can do and seems it will not impact anybody too much as it will be updated at first get next record request.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org