chia7712 opened a new pull request, #13035: URL: https://github.com/apache/kafka/pull/13035
We encountered this error also. The root cause is about race condition. 1. ReplicaAlterLogDirsThread has fetched the data for topic partition 1. ReplicaManager#alterReplicaLogDirs changes the future log (the start offset is reset to 0) 1. ReplicaManager#alterReplicaLogDirs call AbstractFetcherManager#addFetcherForPartitions to add the topic partition (it just change the partition state in the ReplicaAlterLogDirsThread) 1. ReplicaAlterLogDirsThread starts to process the fetched data, and it throws IllegalStateException because the future log get renewed and start offset is zero. ### 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
