David Arthur a1766e02b6 KAFKA-17506 KRaftMigrationDriver initialization race (#17147) ... There is a race condition between KRaftMigrationDriver running its first poll() and being notified by Raft about a leader change. If onControllerChange is called before RecoverMigrationStateFromZKEvent is run, we will end up getting stuck in the INACTIVE state. This patch fixes the race by enqueuing a RecoverMigrationStateFromZKEvent from onControllerChange if the driver has not yet initialized. If another RecoverMigrationStateFromZKEvent was already enqueued, the second one to run will just be ignored. Reviewers: Luke Chen <showuon@gmail.com>		2024-09-11 11:11:40 -04:00
..
src	KAFKA-17506 KRaftMigrationDriver initialization race (#17147)	2024-09-11 11:11:40 -04:00
.gitignore	KAFKA-13429: ignore bin on new modules (#11415)	2021-11-10 14:36:24 -06:00