Jump To Close Expand all Collapse all Table of contents AMQ Streams on OpenShift の使用 多様性を受け入れるオープンソースの強化 1. AMQ Streams の概要 Expand section "1. AMQ Streams の概要" Collapse section "1. AMQ Streams の概要" 1.1. Kafka の機能 1.2. Kafka のユースケース 1.3. AMQ Streams による Kafka のサポート 1.4. AMQ Streams の Operator Expand section "1.4. AMQ Streams の Operator" Collapse section "1.4. AMQ Streams の Operator" 1.4.1. Cluster Operator 1.4.2. Topic Operator 1.4.3. User Operator 1.5. AMQ Streams のカスタムリソース Expand section "1.5. AMQ Streams のカスタムリソース" Collapse section "1.5. AMQ Streams のカスタムリソース" 1.5.1. AMQ Streams カスタムリソースの例 1.6. リスナーの設定 1.7. 本書の表記慣例 2. デプロイメント設定 Expand section "2. デプロイメント設定" Collapse section "2. デプロイメント設定" 2.1. Kafka クラスターの設定 Expand section "2.1. Kafka クラスターの設定" Collapse section "2.1. Kafka クラスターの設定" 2.1.1. Kafka の設定 2.1.2. Entity Operator の設定 Expand section "2.1.2. Entity Operator の設定" Collapse section "2.1.2. Entity Operator の設定" 2.1.2.1. Entity Operator の設定プロパティー 2.1.2.2. Topic Operator 設定プロパティー 2.1.2.3. User Operator 設定プロパティー 2.1.3. Kafka および ZooKeeper のストレージタイプ Expand section "2.1.3. Kafka および ZooKeeper のストレージタイプ" Collapse section "2.1.3. Kafka および ZooKeeper のストレージタイプ" 2.1.3.1. データストレージに関する留意事項 Expand section "2.1.3.1. データストレージに関する留意事項" Collapse section "2.1.3.1. データストレージに関する留意事項" 2.1.3.1.1. ファイルシステム 2.1.3.1.2. Apache Kafka および ZooKeeper ストレージ 2.1.3.2. 一時ストレージ Expand section "2.1.3.2. 一時ストレージ" Collapse section "2.1.3.2. 一時ストレージ" 2.1.3.2.1. ログディレクトリー 2.1.3.3. 永続ストレージ Expand section "2.1.3.3. 永続ストレージ" Collapse section "2.1.3.3. 永続ストレージ" 2.1.3.3.1. ストレージクラスのオーバーライド 2.1.3.3.2. Persistent Volume Claim (永続ボリューム要求、PVC) の命名 2.1.3.3.3. ログディレクトリー 2.1.3.4. 永続ボリュームのサイズ変更 2.1.3.5. JBOD ストレージの概要 Expand section "2.1.3.5. JBOD ストレージの概要" Collapse section "2.1.3.5. JBOD ストレージの概要" 2.1.3.5.1. JBOD の設定 2.1.3.5.2. JBOD および 永続ボリューム要求 (PVC) 2.1.3.5.3. ログディレクトリー 2.1.3.6. JBOD ストレージへのボリュームの追加 2.1.3.7. JBOD ストレージからのボリュームの削除 2.1.4. クラスターのスケーリング Expand section "2.1.4. クラスターのスケーリング" Collapse section "2.1.4. クラスターのスケーリング" 2.1.4.1. Kafka クラスターのスケーリング Expand section "2.1.4.1. Kafka クラスターのスケーリング" Collapse section "2.1.4.1. Kafka クラスターのスケーリング" 2.1.4.1.1. ブローカーのクラスターへの追加 2.1.4.1.2. クラスターからのブローカーの削除 2.1.4.2. パーティションの再割り当て Expand section "2.1.4.2. パーティションの再割り当て" Collapse section "2.1.4.2. パーティションの再割り当て" 2.1.4.2.1. 再割り当て JSON ファイル 2.1.4.2.2. JBOD ボリューム間でのパーティションの再割り当て 2.1.4.3. 再割り当て JSON ファイルの生成 2.1.4.4. 手動による再割り当て JSON ファイルの作成 2.1.4.5. 再割り当てスロットル 2.1.4.6. Kafka クラスターのスケールアップ 2.1.4.7. Kafka クラスターのスケールダウン 2.1.5. ローリングアップデートのメンテナンス時間枠 Expand section "2.1.5. ローリングアップデートのメンテナンス時間枠" Collapse section "2.1.5. ローリングアップデートのメンテナンス時間枠" 2.1.5.1. メンテナンス時間枠の概要 2.1.5.2. メンテナンス時間枠の定義 2.1.5.3. メンテナンス時間枠の設定 2.1.6. ターミナルからの ZooKeeper への接続 2.1.7. Kafka ノードの手動による削除 2.1.8. ZooKeeper ノードの手動による削除 2.1.9. Kafka クラスターリソースのリスト 2.2. Kafka Connect/S2I クラスターの設定 Expand section "2.2. Kafka Connect/S2I クラスターの設定" Collapse section "2.2. Kafka Connect/S2I クラスターの設定" 2.2.1. Kafka Connect の設定 2.2.2. 複数インスタンスの Kafka Connect 設定 2.2.3. Kafka Connect のユーザー承認の設定 2.2.4. Kafka コネクターの再起動の実行 2.2.5. Kafka コネクタータスクの再起動の実行 2.2.6. S2I を使用する Kafka Connect から Kafka Connect への移行 2.2.7. Kafka Connect クラスターリソースの一覧 2.2.8. Kafka Connect (S2I) クラスターリソースの一覧 2.2.9. 変更データキャプチャーのための Debezium との統合 2.3. Kafka MirrorMaker クラスターの設定 Expand section "2.3. Kafka MirrorMaker クラスターの設定" Collapse section "2.3. Kafka MirrorMaker クラスターの設定" 2.3.1. Kafka MirrorMaker の設定 2.3.2. Kafka MirrorMaker クラスターリソースの一覧 2.4. Kafka MirrorMaker 2.0 クラスターの設定 Expand section "2.4. Kafka MirrorMaker 2.0 クラスターの設定" Collapse section "2.4. Kafka MirrorMaker 2.0 クラスターの設定" 2.4.1. MirrorMaker 2.0 のデータレプリケーション 2.4.2. クラスターの設定 Expand section "2.4.2. クラスターの設定" Collapse section "2.4.2. クラスターの設定" 2.4.2.1. 双方向レプリケーション (active/active) 2.4.2.2. 一方向レプリケーション (active/passive) 2.4.2.3. トピック設定の同期 2.4.2.4. データの整合性 2.4.2.5. オフセットの追跡 2.4.2.6. コンシューマーグループオフセットの同期 2.4.2.7. 接続性チェック 2.4.3. ACL ルールの同期 2.4.4. MirrorMaker 2.0 を使用した Kafka クラスター間でのデータの同期 2.4.5. Kafka MirrorMaker 2.0 コネクターの再起動の実行 2.4.6. Kafka MirrorMaker 2.0 コネクタータスクの再起動の実行 2.5. Kafka Bridge クラスターの設定 Expand section "2.5. Kafka Bridge クラスターの設定" Collapse section "2.5. Kafka Bridge クラスターの設定" 2.5.1. Kafka Bridge の設定 2.5.2. Kafka Bridge クラスターリソースのリスト 2.6. OpenShift リソースのカスタマイズ Expand section "2.6. OpenShift リソースのカスタマイズ" Collapse section "2.6. OpenShift リソースのカスタマイズ" 2.6.1. イメージプルポリシーのカスタマイズ 2.7. Pod スケジューリングの設定 Expand section "2.7. Pod スケジューリングの設定" Collapse section "2.7. Pod スケジューリングの設定" 2.7.1. アフィニティー、容認 (Toleration)、およびトポロジー分散制約の指定 Expand section "2.7.1. アフィニティー、容認 (Toleration)、およびトポロジー分散制約の指定" Collapse section "2.7.1. アフィニティー、容認 (Toleration)、およびトポロジー分散制約の指定" 2.7.1.1. Pod の非アフィニティーを使用して重要なアプリケーションがノードを共有しないようにする 2.7.1.2. ノードのアフィニティーを使用したワークロードの特定ノードへのスケジュール 2.7.1.3. 専用ノードへのノードのアフィニティーと容認 (Toleration) の使用 2.7.2. Kafka コンポーネントでの Pod の非アフィニティーの設定 2.7.3. Kafka コンポーネントでのノードのアフィニティーの設定 2.7.4. 専用ノードの設定と Pod のスケジューリング 2.8. 外部ロギング Expand section "2.8. 外部ロギング" Collapse section "2.8. 外部ロギング" 2.8.1. ロギングの ConfigMap の作成 3. 外部リスナーの設定 Expand section "3. 外部リスナーの設定" Collapse section "3. 外部リスナーの設定" 3.1. ノードポートを使用した Kafka へのアクセス 3.2. ロードバランサーを使用した Kafka へのアクセス 3.3. ingress を使用した Kafka へのアクセス 3.4. OpenShift ルートを使用した Kafka へのアクセス 4. Kafka へのセキュアなアクセスの管理 Expand section "4. Kafka へのセキュアなアクセスの管理" Collapse section "4. Kafka へのセキュアなアクセスの管理" 4.1. Kafka のセキュリティーオプション Expand section "4.1. Kafka のセキュリティーオプション" Collapse section "4.1. Kafka のセキュリティーオプション" 4.1.1. リスナー認証 Expand section "4.1.1. リスナー認証" Collapse section "4.1.1. リスナー認証" 4.1.1.1. 相互 TLS 認証 4.1.1.2. SCRAM-SHA-512 認証 4.1.1.3. ネットワークポリシー 4.1.1.4. 追加のリスナー設定オプション 4.1.2. Kafka の承認 Expand section "4.1.2. Kafka の承認" Collapse section "4.1.2. Kafka の承認" 4.1.2.1. スーパーユーザー 4.2. Kafka クライアントのセキュリティーオプション Expand section "4.2. Kafka クライアントのセキュリティーオプション" Collapse section "4.2. Kafka クライアントのセキュリティーオプション" 4.2.1. ユーザー処理用の Kafka クラスターの特定 4.2.2. ユーザー認証 Expand section "4.2.2. ユーザー認証" Collapse section "4.2.2. ユーザー認証" 4.2.2.1. TLS クライアント認証 4.2.2.2. SCRAM-SHA-512 認証 4.2.3. ユーザーの承認 Expand section "4.2.3. ユーザーの承認" Collapse section "4.2.3. ユーザーの承認" 4.2.3.1. ACL ルール 4.2.3.2. Kafka ブローカーへのスーパーユーザーアクセス 4.2.3.3. ユーザークォータ 4.3. Kafka ブローカーへのアクセスのセキュア化 Expand section "4.3. Kafka ブローカーへのアクセスのセキュア化" Collapse section "4.3. Kafka ブローカーへのアクセスのセキュア化" 4.3.1. Kafka ブローカーのセキュア化 4.3.2. Kafka へのユーザーアクセスのセキュア化 4.3.3. ネットワークポリシーを使用した Kafka リスナーへのアクセス制限 4.4. OAuth 2.0 トークンベース認証の使用 Expand section "4.4. OAuth 2.0 トークンベース認証の使用" Collapse section "4.4. OAuth 2.0 トークンベース認証の使用" 4.4.1. OAuth 2.0 認証メカニズム 4.4.2. OAuth 2.0 Kafka ブローカーの設定 Expand section "4.4.2. OAuth 2.0 Kafka ブローカーの設定" Collapse section "4.4.2. OAuth 2.0 Kafka ブローカーの設定" 4.4.2.1. 承認サーバーの OAuth 2.0 クライアント設定 4.4.2.2. Kafka クラスターでの OAuth 2.0 認証設定 4.4.2.3. 高速なローカル JWT トークン検証の設定 4.4.2.4. OAuth 2.0 イントロスペクションエンドポイントの設定 4.4.3. Kafka ブローカーの再認証の設定 4.4.4. OAuth 2.0 Kafka クライアントの設定 4.4.5. OAuth 2.0 のクライアント認証フロー Expand section "4.4.5. OAuth 2.0 のクライアント認証フロー" Collapse section "4.4.5. OAuth 2.0 のクライアント認証フロー" 4.4.5.1. クライアント認証フローの例 4.4.6. OAuth 2.0 認証の設定 Expand section "4.4.6. OAuth 2.0 認証の設定" Collapse section "4.4.6. OAuth 2.0 認証の設定" 4.4.6.1. OAuth 2.0 承認サーバーとしての Red Hat Single Sign-On の設定 4.4.6.2. Kafka ブローカーの OAuth 2.0 サポートの設定 4.4.6.3. OAuth 2.0 を使用するよう Kafka Java クライアントを設定 4.4.6.4. Kafka コンポーネントの OAuth 2.0 の設定 4.5. OAuth 2.0 トークンベース承認の使用 Expand section "4.5. OAuth 2.0 トークンベース承認の使用" Collapse section "4.5. OAuth 2.0 トークンベース承認の使用" 4.5.1. OAuth 2.0 の承認メカニズム Expand section "4.5.1. OAuth 2.0 の承認メカニズム" Collapse section "4.5.1. OAuth 2.0 の承認メカニズム" 4.5.1.1. Kafka ブローカーのカスタムオーソライザー 4.5.2. OAuth 2.0 承認サポートの設定 5. AMQ Streams operator の使用 Expand section "5. AMQ Streams operator の使用" Collapse section "5. AMQ Streams operator の使用" 5.1. Cluster Operator の使用 Expand section "5.1. Cluster Operator の使用" Collapse section "5.1. Cluster Operator の使用" 5.1.1. Cluster Operator の設定 Expand section "5.1.1. Cluster Operator の設定" Collapse section "5.1.1. Cluster Operator の設定" 5.1.1.1. ConfigMap による設定のロギング 5.1.1.2. ネットワークポリシーによる Cluster Operator アクセスの制限 5.1.1.3. 定期的な調整 5.1.2. ロールベースアクセス制御 (RBAC) のプロビジョニング Expand section "5.1.2. ロールベースアクセス制御 (RBAC) のプロビジョニング" Collapse section "5.1.2. ロールベースアクセス制御 (RBAC) のプロビジョニング" 5.1.2.1. 委譲された権限 5.1.2.2. ServiceAccount 5.1.2.3. ClusterRoles 5.1.2.4. ClusterRoleBindings 5.2. Topic Operator の使用 Expand section "5.2. Topic Operator の使用" Collapse section "5.2. Topic Operator の使用" 5.2.1. Kafka トピックリソース Expand section "5.2.1. Kafka トピックリソース" Collapse section "5.2.1. Kafka トピックリソース" 5.2.1.1. トピック処理用の Kafka クラスターの特定 5.2.1.2. Kafka トピックの使用に関する推奨事項 5.2.1.3. Kafka トピックの命名規則 5.2.2. Topic Operator のトピックストア Expand section "5.2.2. Topic Operator のトピックストア" Collapse section "5.2.2. Topic Operator のトピックストア" 5.2.2.1. 内部トピックストアトピック 5.2.2.2. ZooKeeper からのトピックメタデータの移行 5.2.2.3. ZooKeeper を使用してトピックメタデータを保存する AMQ Streams バージョンへのダウングレード 5.2.2.4. Topic Operator トピックのレプリケーションおよびスケーリング 5.2.2.5. トピック変更の処理 5.2.3. Kafka トピックの設定 5.2.4. リソース要求および制限のある Topic Operator の設定 5.3. User Operator の使用 Expand section "5.3. User Operator の使用" Collapse section "5.3. User Operator の使用" 5.3.1. リソース要求および制限のある User Operator の設定 5.4. Prometheus メトリクスを使用した Operator の監視 6. Kafka Bridge Expand section "6. Kafka Bridge" Collapse section "6. Kafka Bridge" 6.1. Kafka Bridge の概要 Expand section "6.1. Kafka Bridge の概要" Collapse section "6.1. Kafka Bridge の概要" 6.1.1. Kafka Bridge インターフェース Expand section "6.1.1. Kafka Bridge インターフェース" Collapse section "6.1.1. Kafka Bridge インターフェース" 6.1.1.1. HTTP リクエスト 6.1.2. Kafka Bridge でサポートされるクライアント 6.1.3. Kafka Bridge のセキュリティー保護 6.1.4. OpenShift 外部の Kafka Bridge へのアクセス 6.1.5. Kafka Bridge へのリクエスト Expand section "6.1.5. Kafka Bridge へのリクエスト" Collapse section "6.1.5. Kafka Bridge へのリクエスト" 6.1.5.1. コンテンツタイプヘッダー 6.1.5.2. 埋め込みデータ形式 6.1.5.3. メッセージの形式 6.1.5.4. Accept ヘッダー 6.1.6. CORS Expand section "6.1.6. CORS" Collapse section "6.1.6. CORS" 6.1.6.1. シンプルなリクエスト 6.1.6.2. プリフライトリクエスト 6.1.7. Kafka Bridge API リソース 6.1.8. Kafka Bridge デプロイメント 6.2. Kafka Bridge クイックスタート Expand section "6.2. Kafka Bridge クイックスタート" Collapse section "6.2. Kafka Bridge クイックスタート" 6.2.1. OpenShift クラスターへの Kafka Bridge のデプロイメント 6.2.2. Kafka Bridge サービスのローカルマシンへの公開 6.2.3. トピックおよびパーティションへのメッセージの作成 6.2.4. Kafka Bridge コンシューマーの作成 6.2.5. Kafka Bridge コンシューマーのトピックへのサブスクライブ 6.2.6. Kafka Bridge コンシューマーからの最新メッセージの取得 6.2.7. ログへのオフセットのコミット 6.2.8. パーティションのオフセットのシーク 6.2.9. Kafka Bridge コンシューマーの削除 7. 3scale での Kafka Bridge の使用 Expand section "7. 3scale での Kafka Bridge の使用" Collapse section "7. 3scale での Kafka Bridge の使用" 7.1. 3scale での Kafka Bridge の使用 Expand section "7.1. 3scale での Kafka Bridge の使用" Collapse section "7.1. 3scale での Kafka Bridge の使用" 7.1.1. Kafka Bridge のサービス検出 7.1.2. 3scale APIcast ゲートウェイポリシー 7.1.3. TLS の検証 7.1.4. 3scale ドキュメント 7.2. Kafka Bridge を使用するための 3scale のデプロイメント 8. Cruise Control によるクラスターのリバランス Expand section "8. Cruise Control によるクラスターのリバランス" Collapse section "8. Cruise Control によるクラスターのリバランス" 8.1. Cruise Control とは 8.2. 最適化ゴールの概要 8.3. 最適化プロポーザルの概要 8.4. リバランスパフォーマンスチューニングの概要 8.5. Cruise Control の設定 8.6. Cruise Control のデプロイ 8.7. 最適化プロポーザルの生成 8.8. 最適化プロポーザルの承認 8.9. クラスターリバランスの停止 8.10. KafkaRebalance リソースの問題の修正 9. Service Registry を使用したスキーマの検証 10. 分散トレーシング Expand section "10. 分散トレーシング" Collapse section "10. 分散トレーシング" 10.1. OpenTracing および Jaeger の概要 10.2. Kafka クライアントのトレーシング設定 Expand section "10.2. Kafka クライアントのトレーシング設定" Collapse section "10.2. Kafka クライアントのトレーシング設定" 10.2.1. Kafka クライアント用の Jaeger トレーサーの初期化 10.2.2. トレーシングの環境変数 10.3. トレーサーでの Kafka クライアントのインストルメント化 Expand section "10.3. トレーサーでの Kafka クライアントのインストルメント化" Collapse section "10.3. トレーサーでの Kafka クライアントのインストルメント化" 10.3.1. トレーシングのための Kafka プロデューサーおよびコンシューマーのインストルメント化 Expand section "10.3.1. トレーシングのための Kafka プロデューサーおよびコンシューマーのインストルメント化" Collapse section "10.3.1. トレーシングのための Kafka プロデューサーおよびコンシューマーのインストルメント化" 10.3.1.1. Decorator パターンのカスタムスパン名 10.3.1.2. ビルトインスパン名 10.3.2. Kafka Streams アプリケーションのトレーシングのインストルメント化 10.4. MirrorMaker、Kafka Connect、および Kafka Bridge のトレーシング設定 Expand section "10.4. MirrorMaker、Kafka Connect、および Kafka Bridge のトレーシング設定" Collapse section "10.4. MirrorMaker、Kafka Connect、および Kafka Bridge のトレーシング設定" 10.4.1. MirrorMaker、Kafka Connect、および Kafka Bridge リソースでのトレーシングの有効化 11. TLS 証明書の管理 Expand section "11. TLS 証明書の管理" Collapse section "11. TLS 証明書の管理" 11.1. 認証局 Expand section "11.1. 認証局" Collapse section "11.1. 認証局" 11.1.1. CA 証明書 11.1.2. 独自の CA 証明書のインストール 11.2. Secret Expand section "11.2. Secret" Collapse section "11.2. Secret" 11.2.1. PKCS #12 ストレージ 11.2.2. クラスター CA Secret 11.2.3. クライアント CA Secret 11.2.4. ラベルおよびアノテーションの Secret への追加 11.2.5. CA Secret での ownerReference の無効化 11.2.6. User Secret 11.3. 証明書の更新および有効期間 Expand section "11.3. 証明書の更新および有効期間" Collapse section "11.3. 証明書の更新および有効期間" 11.3.1. 自動生成された CA 証明書での更新プロセス 11.3.2. クライアント証明書の更新 11.3.3. Cluster Operator によって生成される CA 証明書の手動更新 11.3.4. Cluster Operator によって生成された CA 証明書によって使用される秘密鍵の置き換え 11.3.5. 独自の CA 証明書の更新 11.4. TLS 接続 Expand section "11.4. TLS 接続" Collapse section "11.4. TLS 接続" 11.4.1. ZooKeeper の通信 11.4.2. Kafka のブローカー間の通信 11.4.3. Topic Operator および User Operator 11.4.4. Cruise Control 11.4.5. Kafka クライアント接続 11.5. クラスター CA を信頼する内部クライアントの設定 11.6. クラスター CA を信頼する外部クライアントの設定 11.7. Kafka リスナー証明書 Expand section "11.7. Kafka リスナー証明書" Collapse section "11.7. Kafka リスナー証明書" 11.7.1. 独自の Kafka リスナー証明書の指定 11.7.2. Kafka リスナーのサーバー証明書の SAN Expand section "11.7.2. Kafka リスナーのサーバー証明書の SAN" Collapse section "11.7.2. Kafka リスナーのサーバー証明書の SAN" 11.7.2.1. TLS リスナー SAN の例 11.7.2.2. 外部リスナー SAN の例 12. AMQ Streams の管理 Expand section "12. AMQ Streams の管理" Collapse section "12. AMQ Streams の管理" 12.1. カスタムリソースの使用 Expand section "12.1. カスタムリソースの使用" Collapse section "12.1. カスタムリソースの使用" 12.1.1. カスタムリソースでの oc 操作の実行 Expand section "12.1.1. カスタムリソースでの oc 操作の実行" Collapse section "12.1.1. カスタムリソースでの oc 操作の実行" 12.1.1.1. リソースカテゴリー 12.1.1.2. サブリソースのステータスのクエリー 12.1.2. AMQ Streams カスタムリソースのステータス情報 12.1.3. カスタムリソースのステータスの検出 12.2. カスタムリソースの調整の一時停止 12.3. Kafka および ZooKeeper クラスターの手動によるローリングアップデートの開始 Expand section "12.3. Kafka および ZooKeeper クラスターの手動によるローリングアップデートの開始" Collapse section "12.3. Kafka および ZooKeeper クラスターの手動によるローリングアップデートの開始" 12.3.1. 前提条件 12.3.2. StatefulSet アノテーションを使用したローリングアップデートの実行 12.3.3. Pod アノテーションを使用したローリングアップデートの実行 12.4. ラベルおよびアノテーションを使用したサービスの検出 Expand section "12.4. ラベルおよびアノテーションを使用したサービスの検出" Collapse section "12.4. ラベルおよびアノテーションを使用したサービスの検出" 12.4.1. サービスの接続詳細の返信 12.5. 永続ボリュームからのクラスターの復元 Expand section "12.5. 永続ボリュームからのクラスターの復元" Collapse section "12.5. 永続ボリュームからのクラスターの復元" 12.5.1. namespace が削除された場合の復元 12.5.2. OpenShift クラスター喪失からの復旧 12.5.3. 削除したクラスターの永続ボリュームからの復元 12.6. クライアント設定のチューニング Expand section "12.6. クライアント設定のチューニング" Collapse section "12.6. クライアント設定のチューニング" 12.6.1. Kafka プロデューサー設定のチューニング Expand section "12.6.1. Kafka プロデューサー設定のチューニング" Collapse section "12.6.1. Kafka プロデューサー設定のチューニング" 12.6.1.1. 基本のプロデューサー設定 12.6.1.2. データの持続性 12.6.1.3. 順序付き配信 12.6.1.4. 信頼性の保証 12.6.1.5. スループットおよびレイテンシーの最適化 12.6.2. Kafka コンシューマー設定の調整 Expand section "12.6.2. Kafka コンシューマー設定の調整" Collapse section "12.6.2. Kafka コンシューマー設定の調整" 12.6.2.1. 基本的なコンシューマー設定 12.6.2.2. コンシューマーグループを使用したデータ消費のスケーリング 12.6.2.3. メッセージの順序の保証 12.6.2.4. スループットおよびレイテンシーの最適化 12.6.2.5. オフセットをコミットする際のデータ損失または重複の回避 Expand section "12.6.2.5. オフセットをコミットする際のデータ損失または重複の回避" Collapse section "12.6.2.5. オフセットをコミットする際のデータ損失または重複の回避" 12.6.2.5.1. トランザクションメッセージの制御 12.6.2.6. データ損失を回避するための障害からの復旧 12.6.2.7. オフセットポリシーの管理 12.6.2.8. リバランスの影響を最小限にする 12.7. AMQ Streams のアンインストール 12.8. よくある質問 Expand section "12.8. よくある質問" Collapse section "12.8. よくある質問" 12.8.1. Cluster Operator に関する質問 Expand section "12.8.1. Cluster Operator に関する質問" Collapse section "12.8.1. Cluster Operator に関する質問" 12.8.1.1. AMQ Streams のインストールに、クラスター管理者の権限が必要なのはなぜですか? 12.8.1.2. Cluster Operator が ClusterRoleBindings を作成する必要があるのはなぜですか? 12.8.1.3. OpenShift の標準ユーザーは Kafka カスタムリソースを作成できますか? 12.8.1.4. ログの Failed to acquire lock 警告の意味 12.8.1.5. TLS を使用して NodePort に接続するとホスト名の検証に失敗するのはなぜですか? 13. カスタムリソース API のリファレンス Expand section "13. カスタムリソース API のリファレンス" Collapse section "13. カスタムリソース API のリファレンス" 13.1. 共通の設定プロパティー Expand section "13.1. 共通の設定プロパティー" Collapse section "13.1. 共通の設定プロパティー" 13.1.1. replicas 13.1.2. bootstrapServers 13.1.3. ssl 13.1.4. trustedCertificates 13.1.5. resources 13.1.6. image 13.1.7. livenessProbe および readinessProbe ヘルスチェック 13.1.8. metricsConfig 13.1.9. jvmOptions 13.1.10. ガベッジコレクターのロギング 13.2. スキーマプロパティー Expand section "13.2. スキーマプロパティー" Collapse section "13.2. スキーマプロパティー" 13.2.1. Kafka スキーマ参照 13.2.2. KafkaSpec スキーマ参照 13.2.3. KafkaClusterSpec スキーマ参照 Expand section "13.2.3. KafkaClusterSpec スキーマ参照" Collapse section "13.2.3. KafkaClusterSpec スキーマ参照" 13.2.3.1. listeners 13.2.3.2. config 13.2.3.3. brokerRackInitImage 13.2.3.4. logging 13.2.3.5. KafkaClusterSpec スキーマプロパティー 13.2.4. GenericKafkaListener スキーマ参照 Expand section "13.2.4. GenericKafkaListener スキーマ参照" Collapse section "13.2.4. GenericKafkaListener スキーマ参照" 13.2.4.1. listeners 13.2.4.2. type 13.2.4.3. port 13.2.4.4. tls 13.2.4.5. authentication 13.2.4.6. networkPolicyPeers 13.2.4.7. GenericKafkaListener スキーマプロパティー 13.2.5. KafkaListenerAuthenticationTls スキーマ参照 13.2.6. KafkaListenerAuthenticationScramSha512 スキーマ参照 13.2.7. KafkaListenerAuthenticationOAuth スキーマ参照 13.2.8. GenericSecretSource スキーマ参照 13.2.9. CertSecretSource スキーマ参照 13.2.10. GenericKafkaListenerConfiguration スキーマ参照 Expand section "13.2.10. GenericKafkaListenerConfiguration スキーマ参照" Collapse section "13.2.10. GenericKafkaListenerConfiguration スキーマ参照" 13.2.10.1. brokerCertChainAndKey 13.2.10.2. externalTrafficPolicy 13.2.10.3. loadBalancerSourceRanges 13.2.10.4. class 13.2.10.5. preferredNodePortAddressType 13.2.10.6. useServiceDnsDomain 13.2.10.7. GenericKafkaListenerConfiguration スキーマプロパティー 13.2.11. CertAndKeySecretSource スキーマ参照 13.2.12. GenericKafkaListenerConfigurationBootstrap スキーマ参照 Expand section "13.2.12. GenericKafkaListenerConfigurationBootstrap スキーマ参照" Collapse section "13.2.12. GenericKafkaListenerConfigurationBootstrap スキーマ参照" 13.2.12.1. alternativeNames 13.2.12.2. host 13.2.12.3. nodePort 13.2.12.4. loadBalancerIP 13.2.12.5. annotations 13.2.12.6. GenericKafkaListenerConfigurationBootstrap スキーマプロパティー 13.2.13. GenericKafkaListenerConfigurationBroker スキーマ参照 Expand section "13.2.13. GenericKafkaListenerConfigurationBroker スキーマ参照" Collapse section "13.2.13. GenericKafkaListenerConfigurationBroker スキーマ参照" 13.2.13.1. GenericKafkaListenerConfigurationBroker スキーマプロパティー 13.2.14. KafkaListeners スキーマ参照 13.2.15. KafkaListenerPlain スキーマ参照 13.2.16. KafkaListenerTls スキーマ参照 13.2.17. TlsListenerConfiguration スキーマ参照 13.2.18. KafkaListenerExternalRoute スキーマ参照 13.2.19. RouteListenerOverride スキーマ参照 13.2.20. RouteListenerBootstrapOverride スキーマ参照 13.2.21. RouteListenerBrokerOverride スキーマ参照 13.2.22. KafkaListenerExternalConfiguration スキーマ参照 13.2.23. KafkaListenerExternalLoadBalancer スキーマ参照 13.2.24. LoadBalancerListenerOverride スキーマ参照 13.2.25. LoadBalancerListenerBootstrapOverride スキーマ参照 13.2.26. LoadBalancerListenerBrokerOverride スキーマ参照 13.2.27. KafkaListenerExternalNodePort スキーマ参照 13.2.28. NodePortListenerOverride スキーマ参照 13.2.29. NodePortListenerBootstrapOverride スキーマ参照 13.2.30. NodePortListenerBrokerOverride スキーマ参照 13.2.31. NodePortListenerConfiguration スキーマ参照 13.2.32. KafkaListenerExternalIngress スキーマ参照 13.2.33. IngressListenerConfiguration スキーマ参照 13.2.34. IngressListenerBootstrapConfiguration スキーマ参照 13.2.35. IngressListenerBrokerConfiguration スキーマ参照 13.2.36. EphemeralStorage スキーマ参照 13.2.37. PersistentClaimStorage スキーマ参照 13.2.38. PersistentClaimStorageOverride スキーマ参照 13.2.39. JbodStorage スキーマ参照 13.2.40. KafkaAuthorizationSimple スキーマ参照 Expand section "13.2.40. KafkaAuthorizationSimple スキーマ参照" Collapse section "13.2.40. KafkaAuthorizationSimple スキーマ参照" 13.2.40.1. superUsers 13.2.40.2. KafkaAuthorizationSimple スキーマプロパティー 13.2.41. KafkaAuthorizationOpa スキーマ参照 Expand section "13.2.41. KafkaAuthorizationOpa スキーマ参照" Collapse section "13.2.41. KafkaAuthorizationOpa スキーマ参照" 13.2.41.1. url 13.2.41.2. allowOnError 13.2.41.3. initialCacheCapacity 13.2.41.4. maximumCacheSize 13.2.41.5. expireAfterMs 13.2.41.6. superUsers 13.2.41.7. KafkaAuthorizationOpa スキーマプロパティー 13.2.42. KafkaAuthorizationKeycloak スキーマ参照 13.2.43. Rack スキーマ参照 Expand section "13.2.43. Rack スキーマ参照" Collapse section "13.2.43. Rack スキーマ参照" 13.2.43.1. Rack スキーマプロパティー 13.2.44. Probe スキーマ参照 13.2.45. JvmOptions スキーマ参照 13.2.46. SystemProperty スキーマ参照 13.2.47. KafkaJmxOptions スキーマ参照 Expand section "13.2.47. KafkaJmxOptions スキーマ参照" Collapse section "13.2.47. KafkaJmxOptions スキーマ参照" 13.2.47.1. KafkaJmxOptions スキーマプロパティー 13.2.48. KafkaJmxAuthenticationPassword スキーマ参照 13.2.49. JmxPrometheusExporterMetrics スキーマ参照 13.2.50. ExternalConfigurationReference スキーマ参照 13.2.51. InlineLogging スキーマ参照 13.2.52. ExternalLogging スキーマ参照 13.2.53. TlsSidecar スキーマ参照 Expand section "13.2.53. TlsSidecar スキーマ参照" Collapse section "13.2.53. TlsSidecar スキーマ参照" 13.2.53.1. TlsSidecar スキーマプロパティー 13.2.54. KafkaClusterTemplate スキーマ参照 13.2.55. StatefulSetTemplate スキーマ参照 13.2.56. MetadataTemplate スキーマ参照 Expand section "13.2.56. MetadataTemplate スキーマ参照" Collapse section "13.2.56. MetadataTemplate スキーマ参照" 13.2.56.1. MetadataTemplate スキーマプロパティー 13.2.57. PodTemplate スキーマ参照 Expand section "13.2.57. PodTemplate スキーマ参照" Collapse section "13.2.57. PodTemplate スキーマ参照" 13.2.57.1. hostAliases 13.2.57.2. PodTemplate スキーマプロパティー 13.2.58. ResourceTemplate スキーマ参照 13.2.59. ExternalServiceTemplate スキーマ参照 Expand section "13.2.59. ExternalServiceTemplate スキーマ参照" Collapse section "13.2.59. ExternalServiceTemplate スキーマ参照" 13.2.59.1. ExternalServiceTemplate スキーマプロパティー 13.2.60. PodDisruptionBudgetTemplate スキーマ参照 Expand section "13.2.60. PodDisruptionBudgetTemplate スキーマ参照" Collapse section "13.2.60. PodDisruptionBudgetTemplate スキーマ参照" 13.2.60.1. PodDisruptionBudgetTemplate スキーマプロパティー 13.2.61. ContainerTemplate スキーマ参照 Expand section "13.2.61. ContainerTemplate スキーマ参照" Collapse section "13.2.61. ContainerTemplate スキーマ参照" 13.2.61.1. ContainerTemplate スキーマプロパティー 13.2.62. ContainerEnvVar スキーマ参照 13.2.63. ZookeeperClusterSpec スキーマ参照 Expand section "13.2.63. ZookeeperClusterSpec スキーマ参照" Collapse section "13.2.63. ZookeeperClusterSpec スキーマ参照" 13.2.63.1. config 13.2.63.2. logging 13.2.63.3. ZookeeperClusterSpec スキーマプロパティー 13.2.64. ZookeeperClusterTemplate スキーマ参照 13.2.65. TopicOperatorSpec スキーマ参照 13.2.66. EntityOperatorSpec スキーマ参照 13.2.67. EntityTopicOperatorSpec スキーマ参照 Expand section "13.2.67. EntityTopicOperatorSpec スキーマ参照" Collapse section "13.2.67. EntityTopicOperatorSpec スキーマ参照" 13.2.67.1. logging 13.2.67.2. EntityTopicOperatorSpec スキーマプロパティー 13.2.68. EntityUserOperatorSpec スキーマ参照 Expand section "13.2.68. EntityUserOperatorSpec スキーマ参照" Collapse section "13.2.68. EntityUserOperatorSpec スキーマ参照" 13.2.68.1. logging 13.2.68.2. EntityUserOperatorSpec スキーマプロパティー 13.2.69. EntityOperatorTemplate スキーマ参照 13.2.70. CertificateAuthority スキーマ参照 13.2.71. CruiseControlSpec スキーマ参照 13.2.72. CruiseControlTemplate スキーマ参照 13.2.73. BrokerCapacity スキーマ参照 13.2.74. KafkaExporterSpec スキーマ参照 13.2.75. KafkaExporterTemplate スキーマ参照 13.2.76. KafkaStatus スキーマ参照 13.2.77. Condition スキーマ参照 13.2.78. ListenerStatus スキーマ参照 13.2.79. ListenerAddress スキーマ参照 13.2.80. KafkaConnect スキーマ参照 13.2.81. KafkaConnectSpec スキーマ参照 Expand section "13.2.81. KafkaConnectSpec スキーマ参照" Collapse section "13.2.81. KafkaConnectSpec スキーマ参照" 13.2.81.1. config 13.2.81.2. logging 13.2.81.3. KafkaConnectSpec スキーマプロパティー 13.2.82. KafkaConnectTls スキーマ参照 Expand section "13.2.82. KafkaConnectTls スキーマ参照" Collapse section "13.2.82. KafkaConnectTls スキーマ参照" 13.2.82.1. trustedCertificates 13.2.82.2. KafkaConnectTls スキーマプロパティー 13.2.83. KafkaClientAuthenticationTls スキーマ参照 Expand section "13.2.83. KafkaClientAuthenticationTls スキーマ参照" Collapse section "13.2.83. KafkaClientAuthenticationTls スキーマ参照" 13.2.83.1. certificateAndKey 13.2.83.2. KafkaClientAuthenticationTls スキーマプロパティー 13.2.84. KafkaClientAuthenticationScramSha512 スキーマ参照 Expand section "13.2.84. KafkaClientAuthenticationScramSha512 スキーマ参照" Collapse section "13.2.84. KafkaClientAuthenticationScramSha512 スキーマ参照" 13.2.84.1. username 13.2.84.2. passwordSecret 13.2.84.3. KafkaClientAuthenticationScramSha512 スキーマプロパティー 13.2.85. PasswordSecretSource スキーマ参照 13.2.86. KafkaClientAuthenticationPlain スキーマ参照 Expand section "13.2.86. KafkaClientAuthenticationPlain スキーマ参照" Collapse section "13.2.86. KafkaClientAuthenticationPlain スキーマ参照" 13.2.86.1. username 13.2.86.2. passwordSecret 13.2.86.3. KafkaClientAuthenticationPlain スキーマプロパティー 13.2.87. KafkaClientAuthenticationOAuth スキーマ参照 Expand section "13.2.87. KafkaClientAuthenticationOAuth スキーマ参照" Collapse section "13.2.87. KafkaClientAuthenticationOAuth スキーマ参照" 13.2.87.1. KafkaClientAuthenticationOAuth スキーマプロパティー 13.2.88. JaegerTracing スキーマ参照 13.2.89. KafkaConnectTemplate スキーマ参照 13.2.90. DeploymentTemplate スキーマ参照 13.2.91. ExternalConfiguration スキーマ参照 Expand section "13.2.91. ExternalConfiguration スキーマ参照" Collapse section "13.2.91. ExternalConfiguration スキーマ参照" 13.2.91.1. env 13.2.91.2. volumes 13.2.91.3. ExternalConfiguration スキーマプロパティー 13.2.92. ExternalConfigurationEnv スキーマ参照 13.2.93. ExternalConfigurationEnvVarSource スキーマ参照 13.2.94. ExternalConfigurationVolumeSource スキーマ参照 13.2.95. Build スキーマ参照 Expand section "13.2.95. Build スキーマ参照" Collapse section "13.2.95. Build スキーマ参照" 13.2.95.1. output 13.2.95.2. plugins 13.2.95.3. Build スキーマプロパティー 13.2.96. DockerOutput スキーマ参照 13.2.97. ImageStreamOutput スキーマ参照 13.2.98. Plugin スキーマ参照 13.2.99. JarArtifact スキーマ参照 13.2.100. TgzArtifact スキーマ参照 13.2.101. ZipArtifact スキーマ参照 13.2.102. KafkaConnectStatus スキーマ参照 13.2.103. ConnectorPlugin スキーマ参照 13.2.104. KafkaConnectS2I スキーマ参照 13.2.105. KafkaConnectS2ISpec スキーマ参照 Expand section "13.2.105. KafkaConnectS2ISpec スキーマ参照" Collapse section "13.2.105. KafkaConnectS2ISpec スキーマ参照" 13.2.105.1. KafkaConnectS2ISpec スキーマプロパティー 13.2.106. KafkaConnectS2IStatus スキーマ参照 13.2.107. KafkaTopic スキーマ参照 13.2.108. KafkaTopicSpec スキーマ参照 13.2.109. KafkaTopicStatus スキーマ参照 13.2.110. KafkaUser スキーマ参照 13.2.111. KafkaUserSpec スキーマ参照 13.2.112. KafkaUserTlsClientAuthentication スキーマ参照 13.2.113. KafkaUserScramSha512ClientAuthentication スキーマ参照 13.2.114. KafkaUserAuthorizationSimple スキーマ参照 13.2.115. AclRule スキーマ参照 Expand section "13.2.115. AclRule スキーマ参照" Collapse section "13.2.115. AclRule スキーマ参照" 13.2.115.1. resource 13.2.115.2. type 13.2.115.3. operation 13.2.115.4. host 13.2.115.5. AclRule スキーマプロパティー 13.2.116. AclRuleTopicResource スキーマ参照 13.2.117. AclRuleGroupResource スキーマ参照 13.2.118. AclRuleClusterResource スキーマ参照 13.2.119. AclRuleTransactionalIdResource スキーマ参照 13.2.120. KafkaUserQuotas スキーマ参照 Expand section "13.2.120. KafkaUserQuotas スキーマ参照" Collapse section "13.2.120. KafkaUserQuotas スキーマ参照" 13.2.120.1. quotas 13.2.120.2. KafkaUserQuotas スキーマプロパティー 13.2.121. KafkaUserTemplate スキーマ参照 Expand section "13.2.121. KafkaUserTemplate スキーマ参照" Collapse section "13.2.121. KafkaUserTemplate スキーマ参照" 13.2.121.1. KafkaUserTemplate スキーマプロパティー 13.2.122. KafkaUserStatus スキーマ参照 13.2.123. KafkaMirrorMaker スキーマ参照 13.2.124. KafkaMirrorMakerSpec スキーマ参照 Expand section "13.2.124. KafkaMirrorMakerSpec スキーマ参照" Collapse section "13.2.124. KafkaMirrorMakerSpec スキーマ参照" 13.2.124.1. whitelist 13.2.124.2. KafkaMirrorMakerConsumerSpec および KafkaMirrorMakerProducerSpec 13.2.124.3. logging 13.2.124.4. KafkaMirrorMakerSpec スキーマプロパティー 13.2.125. KafkaMirrorMakerConsumerSpec スキーマ参照 Expand section "13.2.125. KafkaMirrorMakerConsumerSpec スキーマ参照" Collapse section "13.2.125. KafkaMirrorMakerConsumerSpec スキーマ参照" 13.2.125.1. numStreams 13.2.125.2. offsetCommitInterval 13.2.125.3. config 13.2.125.4. groupId 13.2.125.5. KafkaMirrorMakerConsumerSpec スキーマプロパティー 13.2.126. KafkaMirrorMakerTls スキーマ参照 Expand section "13.2.126. KafkaMirrorMakerTls スキーマ参照" Collapse section "13.2.126. KafkaMirrorMakerTls スキーマ参照" 13.2.126.1. trustedCertificates 13.2.126.2. KafkaMirrorMakerTls スキーマプロパティー 13.2.127. KafkaMirrorMakerProducerSpec スキーマ参照 Expand section "13.2.127. KafkaMirrorMakerProducerSpec スキーマ参照" Collapse section "13.2.127. KafkaMirrorMakerProducerSpec スキーマ参照" 13.2.127.1. abortOnSendFailure 13.2.127.2. config 13.2.127.3. KafkaMirrorMakerProducerSpec スキーマプロパティー 13.2.128. KafkaMirrorMakerTemplate スキーマ参照 13.2.129. KafkaMirrorMakerStatus スキーマ参照 13.2.130. KafkaBridge スキーマ参照 13.2.131. KafkaBridgeSpec スキーマ参照 Expand section "13.2.131. KafkaBridgeSpec スキーマ参照" Collapse section "13.2.131. KafkaBridgeSpec スキーマ参照" 13.2.131.1. logging 13.2.131.2. KafkaBridgeSpec スキーマプロパティー 13.2.132. KafkaBridgeTls スキーマ参照 13.2.133. KafkaBridgeHttpConfig スキーマ参照 Expand section "13.2.133. KafkaBridgeHttpConfig スキーマ参照" Collapse section "13.2.133. KafkaBridgeHttpConfig スキーマ参照" 13.2.133.1. cors 13.2.133.2. KafkaBridgeHttpConfig スキーマプロパティー 13.2.134. KafkaBridgeHttpCors スキーマ参照 13.2.135. KafkaBridgeConsumerSpec スキーマ参照 Expand section "13.2.135. KafkaBridgeConsumerSpec スキーマ参照" Collapse section "13.2.135. KafkaBridgeConsumerSpec スキーマ参照" 13.2.135.1. KafkaBridgeConsumerSpec スキーマプロパティー 13.2.136. KafkaBridgeProducerSpec スキーマ参照 Expand section "13.2.136. KafkaBridgeProducerSpec スキーマ参照" Collapse section "13.2.136. KafkaBridgeProducerSpec スキーマ参照" 13.2.136.1. KafkaBridgeProducerSpec スキーマプロパティー 13.2.137. KafkaBridgeTemplate スキーマ参照 13.2.138. KafkaBridgeStatus スキーマ参照 13.2.139. KafkaConnector スキーマ参照 13.2.140. KafkaConnectorSpec スキーマ参照 13.2.141. KafkaConnectorStatus スキーマ参照 13.2.142. KafkaMirrorMaker2 スキーマ参照 13.2.143. KafkaMirrorMaker2Spec スキーマ参照 13.2.144. KafkaMirrorMaker2ClusterSpec スキーマ参照 Expand section "13.2.144. KafkaMirrorMaker2ClusterSpec スキーマ参照" Collapse section "13.2.144. KafkaMirrorMaker2ClusterSpec スキーマ参照" 13.2.144.1. config 13.2.144.2. KafkaMirrorMaker2ClusterSpec スキーマプロパティー 13.2.145. KafkaMirrorMaker2Tls スキーマ参照 13.2.146. KafkaMirrorMaker2MirrorSpec スキーマ参照 13.2.147. KafkaMirrorMaker2ConnectorSpec スキーマ参照 13.2.148. KafkaMirrorMaker2Status スキーマ参照 13.2.149. KafkaRebalance スキーマ参照 13.2.150. KafkaRebalanceSpec スキーマ参照 13.2.151. KafkaRebalanceStatus スキーマ参照 A. サブスクリプションの使用 法律上の通知 Settings Close Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF Language and Page Formatting Options Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF AMQ Streams on OpenShift の使用 Red Hat AMQ 2021.q2OpenShift Container Platform 上で AMQ Streams 1.7 を使用法律上の通知概要 本ガイドでは、Red Hat AMQ Streams をインストール、設定、および管理して、大規模なメッセージングネットワークを構築する方法を説明します。 Next