18.2. Kafka バージョンの更新

クラスター管理に ZooKeeper を使用する場合に Kafka をアップグレードするには、Kafka リソースの設定内の Kafka バージョン (Kafka.spec.kafka.version) とそのブローカー間プロトコルバージョン (inter.broker.protocol.version) を更新する必要があります。Kafka の各バージョンには、互換性のあるバージョンの inter-broker プロトコルがあります。ブローカー間プロトコルは、ブローカー間の通信に使用されます。上記の表が示すように、プロトコルのマイナーバージョンは、通常 Kafka のマイナーバージョンと一致するように番号が増加されます。inter-broker プロトコルのバージョンは、Kafka リソースでクラスター全体に設定されます。これを変更するには、Kafka.spec.kafka.config の inter.broker.protocol.version プロパティーを編集します。

以下の表は、Kafka バージョンの違いを示しています。

特定のメッセージ形式のバージョンを設定するために使用されるプロパティーは以下のとおりです。

Kafka 3.0.0 以降、メッセージ形式のバージョンの値は inter.broker.protocol.version と一致すると見なされ、設定する必要はありません。値は、使用される Kafka バージョンを反映します。

Kafka 3.0.0 以降にアップグレードする場合は、inter.broker.protocol.version を更新する際にこの設定を削除できます。それ以外の場合は、アップグレード先の Kafka バージョンに基づいてメッセージ形式のバージョンを設定できます。

トピックの message.format.version のデフォルト値は、Kafka ブローカーに設定される log.message.format.version によって定義されます。トピックの message.format.version は、トピック設定を編集すると手動で設定できます。

Cluster Operator は、Kafka のアップグレードの一環として、ZooKeeper のローリング更新を開始します。