{"push_id":2762749360,"size":2,"distinct_size":2,"ref":"refs/heads/2.0","head":"b367360889762a7533811357da07bc52255314b6","before":"084f4d2674085157131a2bcce161e906a127fd1f","commits":[{"sha":"2a63c5113902c71a41b9ef48b6fd3cd29b5892da","author":{"name":"Guozhang Wang","email":"fae442ba222671b2ebdf7511c9ca77079c43031b@gmail.com"},"message":"KAFKA-7192: Wipe out if EOS is turned on and checkpoint file does not exist (#5421)\n\n1. As titled and as described in comments.\r\n2. Modified unit test slightly to insert for new keys in committed data to expose this issue.\r\n\r\nReviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>","distinct":true,"url":"https://api.github.com/repos/apache/kafka/commits/2a63c5113902c71a41b9ef48b6fd3cd29b5892da"},{"sha":"b367360889762a7533811357da07bc52255314b6","author":{"name":"Guozhang Wang","email":"fae442ba222671b2ebdf7511c9ca77079c43031b@gmail.com"},"message":"KAFKA-7192 Follow-up: update checkpoint to the reset beginning offset (#5430)\n\n1. When we reinitialize the state store due to no CHECKPOINT with EOS turned on, we should update the checkpoint to consumer.seekToBeginnning() / consumer.position() to avoid falling into endless iterations.\r\n\r\n2. Fixed a few other logic bugs around needsInitializing and needsRestoring.\r\n\r\nReviewers: Jason Gustafson <jason@confluent.io>, Bill Bejeck <bbejeck@gmail.com>","distinct":true,"url":"https://api.github.com/repos/apache/kafka/commits/b367360889762a7533811357da07bc52255314b6"}]}
{"actor":{"display_login":"guozhangwang"}}