brandboat opened a new pull request, #17840: URL: https://github.com/apache/kafka/pull/17840
related to https://issues.apache.org/jira/browse/KAFKA-18003, add test to make sure deleteRecords can handle the corrupted records. test steps are as follows: 1. create topic with 1 partition and 1 replica 1. produces 2 segment, each have 10 records 2. manually load the segment file to corrupt the data 3. failed to consume the all records due to corrupted record 4. add follower to topic 5. call `Admin.deleteRecords` to skip the corrupted record 6. check if the newly added follower is in-sync replica 7. succeed to consume the all records due to corrupted record ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
