7.3. Kafka クラスターの設定

Streams for Apache Kafka は、Kafka および ZooKeeper データを管理するための以下のストレージ設定オプションをサポートします。

これらのオプションに加えて、階層ストレージを使用するように Streams for Apache Kafka を設定できます。階層化ストレージは、Kafka の 早期アクセス 機能であり、特性がっ子となるストレージタイプを並行して使用することで、データ管理の柔軟性を高めます。基本的なストレージオプションの 1 つは階層化ストレージと一緒に設定する必要がありますが、ブロックストレージとオブジェクトストレージなどの組み合わせが可能になり、パフォーマンスとスケーラビリティーが向上します。

ストレージタイプは、storage または tieredStorage 設定プロパティーを使用してカスタムリソースで指定されます。

ディスクに保存される Kafka および ZooKeeper データの場合、ストレージのファイルシステム形式は XFS または EXT4 である必要があります。既存の Kafka クラスターが使用するディスク容量は、増やすことができます (インフラストラクチャーでサポートされる場合)。

リスナーは、クライアントが Kafka クラスターに接続する方法を設定します。

Kafka クラスター内の各リスナーに一意の名前とポートを指定することで、複数のリスナーを設定できます。

以下のタイプのリスナーがサポートされます。

リスナーの TLS 暗号化を有効にし、認証 を設定できます。

内部リスナーは、internal 型を指定して Kafka を公開します。

外部リスナーは、外部用 type を指定して Kafka を公開します。

トークンベースの認証に OAuth 2.0 を使用している場合は、リスナーが認可サーバーを使用するように設定できます。

ラックは、データセンター、データセンター内のラック、または可用性ゾーンを表します。Kafka ブローカー Pod とトピックレプリカをラック全体に分散するようにラック認識を設定します。rack プロパティーを使用してラック認識を有効にし、topologyKey を指定します。topologyKey は、ラックを識別する OpenShift ワーカーノードに割り当てられたラベルの名前です。Streams for Apache Kafka は、各 Kafka ブローカーにラック ID を割り当てます。Kafka ブローカーは ID を使用して、パーティションのレプリカをラック全体に分散させます。ラック認識で使用する RackAwareReplicaSelector セレクタープラグインを指定することもできます。プラグインはブローカーとコンシューマーのラック ID を照合するため、メッセージは最も近いレプリカから消費されます。プラグインを使用するには、コンシューマーもラック認識を有効にする必要があります。Kafka Connect、MirrorMaker 2、および Kafka Bridge でラック認識を有効にすることができます。