Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

MBean nameDescription
kafka.server:type=KafkaServer,name=MigrationStateMetadataType

An enumeration of the possible migration states the broker is in: ZooKeeper (1), Dual (2), KRaft (3). Each broker reports this. All migration states except "MigrationReady" are able to be reported by the brokers.

 kafka.controller:type=KafkaController,name=MigrationStateAn enumeration of the possible migration states the cluster can be in. This is only reported by the active controller. The "ZooKeeper" and "MigrationEligible" states are reported by the ZK controller, while the remaining states are reported by the KRaft controller.
 kafka.controller:type=KafkaController,name=ZooKeeperWriteBehindLagThe amount of lag in records that ZooKeeper is behind relative to the highest committed record in the metadata log. This metric will only be reported by the active KRaft controller.

...

Here is a state machine description of the migration. 


State

Enum

Description

ZooKeeper

1

The cluster is in ZooKeeper mode

MigrationEligible

2

The cluster has been upgraded to a minimum software version and has set the necessary static configs

MigrationReady

3

The KRaft quorum has been started

MigrationActive

4

ZK state has been migrated, controller is in dual-write mode, brokers are being restarted in KRaft mode

MigrationFinished

5

All of the brokers have been restarted in KRaft mode, controller still in dual-write mode

KRaft

6

The cluster is in KRaft mode

...