Minor Description
The KRaftMigrationDriver.checkDriverState is used in multiple implementations of the
MigrationEvent base class but when it comes to log that an event was skipped because the expected state is wrong, it always log "KRafrMigrationDriver" instead of the skipped event.
For example, a logging line could be like this:
2023-10-25 12:17:25,460 INFO [KRaftMigrationDriver id=5] Expected driver state ZK_MIGRATION but found SYNC_KRAFT_TO_ZK. Not running this event KRaftMigrationDriver. (org.apache.kafka.metadata.migration.KRaftMigrationDriver) [controller-5-migration-driver-event-handler]
This is because its code has something like this:
log.info("Expected driver state {} but found {}. Not running this event {}.", expectedState, migrationState, this.getClass().getSimpleName());
Of course, the "this" is referring to the KRafrMigrationDriver class.
It should print the specific skipped event instead.
Attachments
Issue Links
- links to