Hi everyone,
I'd like to discuss the fix for the broker reboot data loss KAFKA-14139
<https://issues.apache.org/jira/browse/KAFKA-14139>.
It changes the Fetch and AlterPartition requests to include the broker
epochs. Then the controller can use these epochs to help reject the stale
AlterPartition request.
Please take a look. Thanks!
https://cwiki.apache.org/confluence/display/KAFKA/KIP-903%3A+Replicas+with+stale+broker+epoch+should+not+be+allowed+to+join+the+ISR

Reply via email to