第9章 デプロイメントの設定


Streams for Apache Kafka カスタムリソースを使用して、Streams for Apache Kafka デプロイメントをニーズに正確に合わせて設定および管理します。Streams for Apache Kafka では、リリースごとにサンプルのカスタムリソースが用意されており、サポートされている Kafka コンポーネントのインスタンスを設定および作成できます。特定の要件に応じて追加機能を組み込むようにカスタムリソースを設定することで、デプロイメントを微調整します。

カスタムリソースを使用して、次のコンポーネントのインスタンスを設定および作成します。

  • Kafka クラスター
  • Kafka Connect クラスター
  • Kafka MirrorMaker
  • Kafka Bridge
  • Cruise Control

設定を使用すると、インスタンスを管理したり、デプロイメントを変更して追加機能を導入したりできます。場合によっては、新しい機能がフィーチャーゲートによって導入されることもあります。フィーチャーゲートは Operator 設定により制御されます。

Streams for Apache Kafka カスタムリソース API リファレンス で、設定で使用できるプロパティーを説明しています。

重要な Kafka 設定オプション

Kafka リソースの設定を通じて、次のものを導入できます。

  • データストレージ
  • ラックアウェアネス
  • Kafka クラスターへの認証済みクライアントアクセス用のリスナー
  • Kafka トピックを管理するための Topic Operator
  • Kafka ユーザー (クライアント) を管理するための User Operator
  • クラスターのリバランスのための Cruise Control
  • ラグメトリクスを収集するための Kafka エクスポーター

Kafka クラスター内の個別のノードグループを設定するには、KafkaNodePool リソースを使用します。

共通の設定

共通の設定は、次のような各コンポーネントごとに個別に設定されます。

  • メトリクスの設定
  • ヘルスチェックと liveness プローブ
  • リソースの制限と要求 (CPU/メモリー)
  • ロギングの頻度
  • 最大および最小メモリー割り当ての JVM オプション

設定を一元管理するための config map

設定の特定の領域、つまりメトリクス、ロギング、Kafka Connect コネクターの外部設定は、ConfigMap リソースを使用することもできます。ConfigMap リソースを使用して設定を組み込むことで、メンテナンスを一元化できます。設定プロバイダーを使用して外部ソースから設定をロードすることもできます。これは、Kafka Connect コネクター設定の認証情報を提供するために推奨されます。

TLS 証明書管理

Kafka をデプロイする場合、Cluster Operator は自動で TLS 証明書の設定および更新を行い、クラスター内での暗号化および認証を有効にします。必要な場合は、更新期間の開始前にクラスターおよびクライアント CA 証明書を手動で更新できます。クラスターおよびクライアント CA 証明書によって使用される鍵を置き換えることもできます。詳細は、CA 証明書の手動更新 および 秘密鍵の置換 を参照してください。

カスタムリソース設定ファイルへの変更の適用

spec プロパティーを使用してカスタムリソースに設定を追加します。設定を追加した後、oc を使用して変更をカスタムリソース設定ファイルに適用できます。

リソース設定ファイルへの変更の適用

oc apply -f <kafka_configuration_file>
Copy to Clipboard Toggle word wrap

注記

カスタムリソースに適用されるラベルは、クラスターを設定する OpenShift リソースにも適用されます。そのため、必要に応じてリソースに簡単にラベルを付けることができます。

9.1. サンプル設定ファイルの使用

追加のサポートされる設定を組み込むことで、デプロイメントをさらに強化します。サンプル設定ファイルは、Streams for Apache Kafka ソフトウェアダウンロードページ からダウンロード可能なリリースアーティファクトに付属しています。

サンプルファイルには、デフォルトでカスタムリソースの必須のプロパティーと値のみが含まれています。oc コマンドラインツールを使用してサンプルをダウンロードおよび適用できます。これらの例は、デプロイメントに独自の Kafka コンポーネント設定を構築する際の開始点として使用できます。

注記

Operator を使用して Streams for Apache Kafka をインストールした場合でも、サンプルファイルをダウンロードし、それらを使用して設定をアップロードできます。

リリースアーティファクトには、examples ディレクトリーがあり、そこに設定例が含まれています。

Streams for Apache Kafka で提供される設定ファイルの例

examples
├── user 
1

├── topic 
2

├── security 
3

│   ├── tls-auth
│   ├── scram-sha-512-auth
│   └── keycloak-authorization
├── mirror-maker 
4

├── metrics 
5

├── kafka 
6

│   └── kraft 
7

├── cruise-control 
8

├── connect 
9

└── bridge 
10
Copy to Clipboard Toggle word wrap

1
User Operator によって管理される KafkaUser カスタムリソース設定。
2
Topic Operator によって管理される KafkaTopic カスタムリソースの設定。
3
Kafka コンポーネントの認証および認可設定。TLS および SCRAM-SHA-512 認証の設定例が含まれています。Red Hat build of Keycloak の例には、Kafka カスタムリソース設定と、Red Hat build of Keycloak のレルム仕様が含まれています。この例を使用して、Red Hat build of Keycloak の認可サービスを試すことができます。また、oauth 認証と keycloak 認可メトリクスを有効にした例もあります。
4
MirrorMaker のデプロイメント用の KafkaMirrorMaker および KafkaMirrorMaker2 カスタムリソース設定。レプリケーションポリシーおよび同期頻度の設定例が含まれます。
5
Prometheus インストールおよび Grafana ダッシュボードファイルが含まれる メトリック設定
6
ZooKeeper モードを使用する Kafka クラスターのデプロイメント用の Kafka および KafkaNodePool カスタムリソース設定。一時的または永続的なシングルまたはマルチノードデプロイメントの設定例が含まれています。
7
KRaft (Kafka Raft メタデータ) モードを使用する Kafka クラスターのデプロイメント用の Kafka および KafkaNodePool 設定。
8
Cruise Control のデプロイ設定を含む Kafka カスタムリソース。デフォルトまたはユーザー最適化ゴールを使用する設定の例とともに、Cruise Control から最適化プロポーザルを生成するための KafkaRebalance カスタムリソースが含まれます。
9
Kafka Connect をデプロイするための KafkaConnect および KafkaConnector カスタムリソース設定。シングルまたはマルチノードデプロイメントの設定例が含まれています。
10
Kafka Bridge をデプロイするための KafkaBridge カスタムリソース設定。
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat