tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-713663078


   @guozhangwang, @hachikuji I was thinking... solving it as I have now 
(keeping track of the epoch) doesn't address another potential problem case 
where the tenure as leader is very short and the background task to load the 
state runs after the background task to unload the state in the same epoch. 
Obviously in this case the load should not be done (I guess it could result in 
a broker not returning NOT_COORDINATOR when it should, based on incorrect state 
of `ownedPartitions`). We could track a high watermark coordinator epoch and 
guard the load with a check (as well as the unload). 


----------------------------------------------------------------
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:
us...@infra.apache.org


Reply via email to