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 YAML の設定例 2.1.2. データストレージに関する留意事項 Expand section "2.1.2. データストレージに関する留意事項" Collapse section "2.1.2. データストレージに関する留意事項" 2.1.2.1. ファイルシステム 2.1.2.2. Apache Kafka および ZooKeeper ストレージ 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.2. 永続ストレージ Expand section "2.1.3.2. 永続ストレージ" Collapse section "2.1.3.2. 永続ストレージ" 2.1.3.2.1. ストレージクラスのオーバーライド 2.1.3.2.2. Persistent Volume Claim (永続ボリューム要求、PVC) の命名 2.1.3.2.3. ログディレクトリー 2.1.3.3. 永続ボリュームのサイズ変更 2.1.3.4. JBOD ストレージの概要 Expand section "2.1.3.4. JBOD ストレージの概要" Collapse section "2.1.3.4. JBOD ストレージの概要" 2.1.3.4.1. JBOD の設定 2.1.3.4.2. JBOD および 永続ボリューム要求 (PVC) 2.1.3.4.3. ログディレクトリー 2.1.3.5. JBOD ストレージへのボリュームの追加 2.1.3.6. JBOD ストレージからのボリュームの削除 2.1.4. Kafka ブローカーレプリカ Expand section "2.1.4. Kafka ブローカーレプリカ" Collapse section "2.1.4. Kafka ブローカーレプリカ" 2.1.4.1. ブローカーノード数の設定 2.1.5. Kafka ブローカーの設定 Expand section "2.1.5. Kafka ブローカーの設定" Collapse section "2.1.5. Kafka ブローカーの設定" 2.1.5.1. Kafka ブローカーの設定 2.1.6. リスナーの設定 2.1.7. ZooKeeper レプリカ Expand section "2.1.7. ZooKeeper レプリカ" Collapse section "2.1.7. ZooKeeper レプリカ" 2.1.7.1. ZooKeeper ノードの数 2.1.7.2. ZooKeeper レプリカの数の変更 2.1.8. ZooKeeper の設定 Expand section "2.1.8. ZooKeeper の設定" Collapse section "2.1.8. ZooKeeper の設定" 2.1.8.1. ZooKeeper の設定 2.1.8.2. ZooKeeper の設定 2.1.9. ZooKeeper の接続 Expand section "2.1.9. ZooKeeper の接続" Collapse section "2.1.9. ZooKeeper の接続" 2.1.9.1. ターミナルからの ZooKeeper への接続 2.1.10. Entitiy Operator Expand section "2.1.10. Entitiy Operator" Collapse section "2.1.10. Entitiy Operator" 2.1.10.1. Entity Operator の設定プロパティー 2.1.10.2. Topic Operator 設定プロパティー 2.1.10.3. User Operator 設定プロパティー 2.1.10.4. Operator ロガー 2.1.10.5. Entity Operator の設定 2.1.11. CPU およびメモリーリソース Expand section "2.1.11. CPU およびメモリーリソース" Collapse section "2.1.11. CPU およびメモリーリソース" 2.1.11.1. リソースの制限および要求 Expand section "2.1.11.1. リソースの制限および要求" Collapse section "2.1.11.1. リソースの制限および要求" 2.1.11.1.1. リソース要求 2.1.11.1.2. リソース制限 2.1.11.1.3. サポートされる CPU 形式 2.1.11.1.4. サポートされるメモリー形式 2.1.11.2. リソース要求および制限の設定 2.1.12. Kafka ロガー 2.1.13. Kafka のラックアウェアネス (Rack awareness) Expand section "2.1.13. Kafka のラックアウェアネス (Rack awareness)" Collapse section "2.1.13. Kafka のラックアウェアネス (Rack awareness)" 2.1.13.1. Kafka ブローカーでのラック認識 (Rack awareness) の設定 2.1.14. ヘルスチェック Expand section "2.1.14. ヘルスチェック" Collapse section "2.1.14. ヘルスチェック" 2.1.14.1. Healthcheck の設定 2.1.14.2. Healthcheck の設定 2.1.15. Prometheus メトリクス Expand section "2.1.15. Prometheus メトリクス" Collapse section "2.1.15. Prometheus メトリクス" 2.1.15.1. メトリクスの設定 2.1.15.2. Prometheus メトリクスの設定 2.1.16. JMX オプション Expand section "2.1.16. JMX オプション" Collapse section "2.1.16. JMX オプション" 2.1.16.1. JMX オプションの設定 2.1.17. JVM オプション Expand section "2.1.17. JVM オプション" Collapse section "2.1.17. JVM オプション" 2.1.17.1. JVM 設定 2.1.17.2. JVM オプションの設定 2.1.18. コンテナーイメージ Expand section "2.1.18. コンテナーイメージ" Collapse section "2.1.18. コンテナーイメージ" 2.1.18.1. コンテナーイメージの設定 2.1.18.2. コンテナーイメージの設定 2.1.19. TLS サイドカー Expand section "2.1.19. TLS サイドカー" Collapse section "2.1.19. TLS サイドカー" 2.1.19.1. TLS サイドカー設定 2.1.19.2. TLS サイドカーの設定 2.1.20. Pod スケジューリングの設定 Expand section "2.1.20. Pod スケジューリングの設定" Collapse section "2.1.20. Pod スケジューリングの設定" 2.1.20.1. 他のアプリケーションに基づく Pod のスケジューリング Expand section "2.1.20.1. 他のアプリケーションに基づく Pod のスケジューリング" Collapse section "2.1.20.1. 他のアプリケーションに基づく Pod のスケジューリング" 2.1.20.1.1. 重要なアプリケーションがノードを共有しないようにする 2.1.20.1.2. アフィニティー 2.1.20.1.3. Kafka コンポーネントでの Pod の非アフィニティーの設定 2.1.20.2. 特定のノードへの Pod のスケジューリング Expand section "2.1.20.2. 特定のノードへの Pod のスケジューリング" Collapse section "2.1.20.2. 特定のノードへの Pod のスケジューリング" 2.1.20.2.1. ノードのスケジューリング 2.1.20.2.2. アフィニティー 2.1.20.2.3. Kafka コンポーネントでのノードのアフィニティーの設定 2.1.20.3. 専用ノードの使用 Expand section "2.1.20.3. 専用ノードの使用" Collapse section "2.1.20.3. 専用ノードの使用" 2.1.20.3.1. 専用ノード 2.1.20.3.2. アフィニティー 2.1.20.3.3. 許容 (Toleration) 2.1.20.3.4. 専用ノードの設定と Pod のスケジューリング 2.1.21. Kafka Exporter 2.1.22. Kafka クラスターのローリングアップデートの実行 2.1.23. ZooKeeper クラスターのローリングアップデートの実行 2.1.24. クラスターのスケーリング Expand section "2.1.24. クラスターのスケーリング" Collapse section "2.1.24. クラスターのスケーリング" 2.1.24.1. Kafka クラスターのスケーリング Expand section "2.1.24.1. Kafka クラスターのスケーリング" Collapse section "2.1.24.1. Kafka クラスターのスケーリング" 2.1.24.1.1. ブローカーのクラスターへの追加 2.1.24.1.2. クラスターからのブローカーの削除 2.1.24.2. パーティションの再割り当て Expand section "2.1.24.2. パーティションの再割り当て" Collapse section "2.1.24.2. パーティションの再割り当て" 2.1.24.2.1. 再割り当て JSON ファイル 2.1.24.2.2. JBOD ボリューム間でのパーティションの再割り当て 2.1.24.3. 再割り当て JSON ファイルの生成 2.1.24.4. 手動による再割り当て JSON ファイルの作成 2.1.24.5. 再割り当てスロットル 2.1.24.6. Kafka クラスターのスケールアップ 2.1.24.7. Kafka クラスターのスケールダウン 2.1.25. Kafka ノードの手動による削除 2.1.26. ZooKeeper ノードの手動による削除 2.1.27. ローリングアップデートのメンテナンス時間枠 Expand section "2.1.27. ローリングアップデートのメンテナンス時間枠" Collapse section "2.1.27. ローリングアップデートのメンテナンス時間枠" 2.1.27.1. メンテナンス時間枠の概要 2.1.27.2. メンテナンス時間枠の定義 2.1.27.3. メンテナンス時間枠の設定 2.1.28. CA 証明書の手動更新 2.1.29. 秘密鍵の交換 2.1.30. 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 Connect クラスターリソースの一覧 2.2.5. Kafka Connect (S2I) クラスターリソースの一覧 2.2.6. 変更データキャプチャーのための 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.3. ACL ルールの同期 2.4.4. MirrorMaker 2.0 を使用した Kafka クラスター間でのデータの同期 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. 外部ロギング Expand section "2.7. 外部ロギング" Collapse section "2.7. 外部ロギング" 2.7.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. 定期的な調整 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. トピック変更の処理 5.2.1.3. Kafka トピックの使用に関する推奨事項 5.2.1.4. Kafka トピックの命名規則 5.2.2. Kafka トピックの設定 5.2.3. リソース要求および制限のある 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 を使用したスキーマの管理 Expand section "9. Service Registry を使用したスキーマの管理" Collapse section "9. Service Registry を使用したスキーマの管理" 9.1. Service Registry を使用する理由 9.2. プロデューサースキーマの設定 9.3. コンシューマースキーマの設定 9.4. スキーマ検索のストラテジー 9.5. Service Registry の定数 9.6. Service Registry のインストール 9.7. スキーマの Service Registry への登録 9.8. プロデューサークライアントからの Service Registry スキーマの使用 9.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. User Secret 11.3. 証明書の更新および有効期間 Expand section "11.3. 証明書の更新および有効期間" Collapse section "11.3. 証明書の更新および有効期間" 11.3.1. 生成された CA での更新プロセス 11.3.2. クライアントアプリケーション Expand section "11.3.2. クライアントアプリケーション" Collapse section "11.3.2. クライアントアプリケーション" 11.3.2.1. クライアント証明書の更新 11.3.3. CA 証明書の手動更新 11.3.4. 独自の CA 証明書の更新 11.4. 秘密鍵の交換 11.5. TLS 接続 Expand section "11.5. TLS 接続" Collapse section "11.5. TLS 接続" 11.5.1. ZooKeeper の通信 11.5.2. Kafka のブローカー間の通信 11.5.3. Topic Operator および User Operator 11.5.4. Cruise Control 11.5.5. Kafka クライアント接続 11.6. クラスター CA を信頼する内部クライアントの設定 11.7. クラスター CA を信頼する外部クライアントの設定 11.8. Kafka リスナー証明書 Expand section "11.8. Kafka リスナー証明書" Collapse section "11.8. Kafka リスナー証明書" 11.8.1. 独自の Kafka リスナー証明書の指定 11.8.2. Kafka リスナーのサーバー証明書の SAN Expand section "11.8.2. Kafka リスナーのサーバー証明書の SAN" Collapse section "11.8.2. Kafka リスナーのサーバー証明書の SAN" 11.8.2.1. TLS リスナー SAN の例 11.8.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. ラベルおよびアノテーションを使用したサービスの検出 Expand section "12.2. ラベルおよびアノテーションを使用したサービスの検出" Collapse section "12.2. ラベルおよびアノテーションを使用したサービスの検出" 12.2.1. サービスの接続詳細の返信 12.3. 永続ボリュームからのクラスターの復元 Expand section "12.3. 永続ボリュームからのクラスターの復元" Collapse section "12.3. 永続ボリュームからのクラスターの復元" 12.3.1. namespace が削除された場合の復元 12.3.2. OpenShift クラスター喪失からの復旧 12.3.3. 削除したクラスターの永続ボリュームからの復元 12.4. クライアント設定のチューニング Expand section "12.4. クライアント設定のチューニング" Collapse section "12.4. クライアント設定のチューニング" 12.4.1. Kafka プロデューサー設定のチューニング Expand section "12.4.1. Kafka プロデューサー設定のチューニング" Collapse section "12.4.1. Kafka プロデューサー設定のチューニング" 12.4.1.1. 基本のプロデューサー設定 12.4.1.2. データの持続性 12.4.1.3. 順序付き配信 12.4.1.4. 信頼性の保証 12.4.1.5. スループットおよびレイテンシーの最適化 12.4.2. Kafka コンシューマー設定の調整 Expand section "12.4.2. Kafka コンシューマー設定の調整" Collapse section "12.4.2. Kafka コンシューマー設定の調整" 12.4.2.1. 基本的なコンシューマー設定 12.4.2.2. コンシューマーグループを使用したデータ消費のスケーリング 12.4.2.3. メッセージの順序の保証 12.4.2.4. スループットおよびレイテンシーの最適化 12.4.2.5. オフセットをコミットする際のデータ損失または重複の回避 Expand section "12.4.2.5. オフセットをコミットする際のデータ損失または重複の回避" Collapse section "12.4.2.5. オフセットをコミットする際のデータ損失または重複の回避" 12.4.2.5.1. トランザクションメッセージの制御 12.4.2.6. データ損失を回避するための障害からの復旧 12.4.2.7. オフセットポリシーの管理 12.4.2.8. リバランスの影響を最小限にする 12.5. AMQ Streams のアンインストール A. よくある質問 Expand section "A. よくある質問" Collapse section "A. よくある質問" A.1. Cluster Operator に関する質問 Expand section "A.1. Cluster Operator に関する質問" Collapse section "A.1. Cluster Operator に関する質問" A.1.1. AMQ Streams のインストールに、クラスター管理者の権限が必要なのはなぜですか? A.1.2. Cluster Operator が ClusterRoleBindings を作成する必要があるのはなぜですか? A.1.3. OpenShift の標準ユーザーは Kafka カスタムリソースを作成できますか? A.1.4. ログの Failed to acquire lock 警告の意味 A.1.5. TLS を使用して NodePort に接続するとホスト名の検証に失敗するのはなぜですか? B. カスタムリソース API のリファレンス Expand section "B. カスタムリソース API のリファレンス" Collapse section "B. カスタムリソース API のリファレンス" B.1. 共通の設定プロパティー Expand section "B.1. 共通の設定プロパティー" Collapse section "B.1. 共通の設定プロパティー" B.1.1. replicas B.1.2. bootstrapServers B.1.3. ssl B.1.4. trustedCertificates B.1.5. resources B.1.6. image B.1.7. livenessProbe および readinessProbe healthcheck B.1.8. metrics B.1.9. jvmOptions B.1.10. ガベッジコレクターのロギング B.2. Kafka スキーマ参照 B.3. KafkaSpec スキーマ参照 B.4. KafkaClusterSpec スキーマ参照 Expand section "B.4. KafkaClusterSpec スキーマ参照" Collapse section "B.4. KafkaClusterSpec スキーマ参照" B.4.1. listeners B.4.2. 設定 B.5. EphemeralStorage スキーマ参照 B.6. PersistentClaimStorage スキーマ参照 B.7. PersistentClaimStorageOverride スキーマ参照 B.8. JbodStorage スキーマ参照 B.9. Generic KafkaListener スキーマ参照 Expand section "B.9. Generic KafkaListener スキーマ参照" Collapse section "B.9. Generic KafkaListener スキーマ参照" B.9.1. listeners B.9.2. type B.9.3. port B.9.4. tls B.9.5. 認証 B.9.6. networkPolicyPeers B.10. KafkaListenerAuthenticationTls スキーマ参照 B.11. KafkaListenerAuthenticationScramSha512 スキーマ参照 B.12. KafkaListenerAuthenticationOAuth スキーマ参照 B.13. GenericSecretSource スキーマ参照 B.14. CertSecretSource スキーマ参照 B.15. GenericKafkaListenerConfiguration スキーマ参照 Expand section "B.15. GenericKafkaListenerConfiguration スキーマ参照" Collapse section "B.15. GenericKafkaListenerConfiguration スキーマ参照" B.15.1. brokerCertChainAndKey B.15.2. externalTrafficPolicy B.15.3. loadBalancerSourceRanges B.15.4. class B.15.5. preferredNodePortAddressType B.15.6. useServiceDnsDomain B.16. CertAndKeySecretSource スキーマ参照 B.17. GenericKafkaListenerConfigurationBootstrap schema reference Expand section "B.17. GenericKafkaListenerConfigurationBootstrap schema reference" Collapse section "B.17. GenericKafkaListenerConfigurationBootstrap schema reference" B.17.1. alternativeNames B.17.2. host B.17.3. nodePort B.17.4. loadBalancerIP B.17.5. annotations B.18. GenericKafkaListenerConfigurationBroker schema reference B.19. KafkaListeners スキーマ参照 B.20. KafkaListenerPlain スキーマ参照 B.21. KafkaListenerTls スキーマ参照 B.22. TlsListenerConfiguration スキーマ参照 B.23. KafkaListenerExternalRoute スキーマ参照 B.24. RouteListenerOverride スキーマ参照 B.25. RouteListenerBootstrapOverride スキーマ参照 B.26. RouteListenerBrokerOverride スキーマ参照 B.27. KafkaListenerExternalConfiguration スキーマ参照 B.28. KafkaListenerExternalLoadBalancer スキーマ参照 B.29. LoadBalancerListenerOverride スキーマ参照 B.30. LoadBalancerListenerBootstrapOverride スキーマ参照 B.31. LoadBalancerListenerBrokerOverride スキーマ参照 B.32. KafkaListenerExternalNodePort スキーマ参照 B.33. NodePortListenerOverride スキーマ参照 B.34. NodePortListenerBootstrapOverride スキーマ参照 B.35. NodePortListenerBrokerOverride スキーマ参照 B.36. NodePortListenerConfiguration スキーマ参照 B.37. KafkaListenerExternalIngress スキーマ参照 B.38. IngressListenerConfiguration スキーマ参照 B.39. IngressListenerBootstrapConfiguration スキーマ参照 B.40. IngressListenerBrokerConfiguration スキーマ参照 B.41. KafkaAuthorizationSimple スキーマ参照 Expand section "B.41. KafkaAuthorizationSimple スキーマ参照" Collapse section "B.41. KafkaAuthorizationSimple スキーマ参照" B.41.1. superUsers B.42. KafkaAuthorizationOpa スキーマ参照 Expand section "B.42. KafkaAuthorizationOpa スキーマ参照" Collapse section "B.42. KafkaAuthorizationOpa スキーマ参照" B.42.1. url B.42.2. allowOnError B.42.3. initialCacheCapacity B.42.4. maximumCacheSize B.42.5. expireAfterMs B.42.6. superUsers B.43. KafkaAuthorizationKeycloak スキーマ参照 B.44. Rack スキーマ参照 B.45. Probe スキーマ参照 B.46. JvmOptions スキーマ参照 B.47. SystemProperty スキーマ参照 B.48. KafkaJmxOptions スキーマ参照 B.49. KafkaJmxAuthenticationPassword スキーマ参照 B.50. InlineLogging スキーマ参照 B.51. ExternalLogging スキーマ参照 B.52. TlsSidecar スキーマ参照 B.53. KafkaClusterTemplate スキーマ参照 B.54. StatefulSetTemplate スキーマ参照 B.55. MetadataTemplate スキーマ参照 B.56. PodTemplate スキーマ参照 Expand section "B.56. PodTemplate スキーマ参照" Collapse section "B.56. PodTemplate スキーマ参照" B.56.1. hostAliases B.57. ResourceTemplate スキーマ参照 B.58. ExternalServiceTemplate スキーマ参照 B.59. PodDisruptionBudgetTemplate スキーマ参照 B.60. ContainerTemplate スキーマ参照 B.61. ContainerEnvVar スキーマ参照 B.62. ZookeeperClusterSpec スキーマ参照 B.63. ZookeeperClusterTemplate スキーマ参照 B.64. TopicOperatorSpec スキーマ参照 B.65. EntityOperatorSpec スキーマ参照 B.66. EntityTopicOperatorSpec スキーマ参照 B.67. EntityUserOperatorSpec スキーマ参照 B.68. EntityOperatorTemplate スキーマ参照 B.69. CertificateAuthority スキーマ参照 B.70. CruiseControlSpec スキーマ参照 B.71. CruiseControlTemplate スキーマ参照 B.72. BrokerCapacity スキーマー参照 B.73. KafkaExporterSpec スキーマ参照 B.74. KafkaExporterTemplate スキーマ参照 B.75. KafkaStatus スキーマ参照 B.76. Condition スキーマ参照 B.77. ListenerStatus スキーマ参照 B.78. ListenerAddress スキーマ参照 B.79. KafkaConnect スキーマ参照 B.80. KafkaConnectSpec スキーマ参照 Expand section "B.80. KafkaConnectSpec スキーマ参照" Collapse section "B.80. KafkaConnectSpec スキーマ参照" B.80.1. 設定 B.80.2. logging B.81. KafkaConnectTls スキーマ参照 Expand section "B.81. KafkaConnectTls スキーマ参照" Collapse section "B.81. KafkaConnectTls スキーマ参照" B.81.1. trustedCertificates B.82. KafkaClientAuthenticationTlsスキーマ参照 Expand section "B.82. KafkaClientAuthenticationTlsスキーマ参照" Collapse section "B.82. KafkaClientAuthenticationTlsスキーマ参照" B.82.1. certificateAndKey B.83. KafkaClientAuthenticationScramSha512 スキーマ参照 Expand section "B.83. KafkaClientAuthenticationScramSha512 スキーマ参照" Collapse section "B.83. KafkaClientAuthenticationScramSha512 スキーマ参照" B.83.1. username B.83.2. passwordSecret B.84. PasswordSecretSource スキーマ参照 B.85. KafkaClientAuthenticationPlain スキーマ参照 Expand section "B.85. KafkaClientAuthenticationPlain スキーマ参照" Collapse section "B.85. KafkaClientAuthenticationPlain スキーマ参照" B.85.1. username B.85.2. passwordSecret B.86. KafkaClientAuthenticationOAuth スキーマ参照 B.87. JaegerTracing スキーマ参照 B.88. KafkaConnectTemplate スキーマ参照 B.89. ExternalConfiguration スキーマ参照 Expand section "B.89. ExternalConfiguration スキーマ参照" Collapse section "B.89. ExternalConfiguration スキーマ参照" B.89.1. env B.89.2. volumes B.90. ExternalConfigurationEnv スキーマ参照 B.91. ExternalConfigurationEnvVarSource スキーマ参照 B.92. ExternalConfigurationVolumeSource スキーマ参照 B.93. KafkaConnectStatus スキーマ参照 B.94. ConnectorPlugin スキーマ参照 B.95. KafkaConnectS2I スキーマ参照 B.96. KafkaConnectS2ISpec スキーマ参照 B.97. KafkaConnectS2IStatus スキーマ参照 B.98. KafkaTopic スキーマ参照 B.99. KafkaTopicSpec スキーマ参照 B.100. KafkaTopicStatus スキーマ参照 B.101. KafkaUser スキーマ参照 B.102. KafkaUserSpec スキーマ参照 B.103. KafkaUserTlsClientAuthentication スキーマ参照 B.104. KafkaUserScramSha512ClientAuthentication スキーマ参照 B.105. KafkaUserAuthorizationSimple スキーマ参照 B.106. AclRule スキーマ参照 Expand section "B.106. AclRule スキーマ参照" Collapse section "B.106. AclRule スキーマ参照" B.106.1. resource B.106.2. type B.106.3. operation B.106.4. host B.107. AclRuleTopicResource スキーマ参照 B.108. AclRuleGroupResource スキーマ参照 B.109. AclRuleClusterResource スキーマ参照 B.110. AclRuleTransactionalIdResource スキーマ参照 B.111. KafkaUserQuotas スキーマ参照 Expand section "B.111. KafkaUserQuotas スキーマ参照" Collapse section "B.111. KafkaUserQuotas スキーマ参照" B.111.1. quotas B.112. KafkaUserTemplate スキーマ参照 B.113. KafkaUserStatus スキーマ参照 B.114. KafkaMirrorMaker スキーマ参照 B.115. KafkaMirrorMakerSpec スキーマ参照 Expand section "B.115. KafkaMirrorMakerSpec スキーマ参照" Collapse section "B.115. KafkaMirrorMakerSpec スキーマ参照" B.115.1. whitelist B.115.2. KafkaMirrorMakerConsumerSpec and KafkaMirrorMakerProducerSpec B.115.3. ログ B.116. KafkaMirrorMakerConsumerSpec スキーマ参照 Expand section "B.116. KafkaMirrorMakerConsumerSpec スキーマ参照" Collapse section "B.116. KafkaMirrorMakerConsumerSpec スキーマ参照" B.116.1. numStreams B.116.2. offsetCommitInterval B.116.3. 設定 B.116.4. groupId B.117. KafkaMirrorMakerTls スキーマ参照 Expand section "B.117. KafkaMirrorMakerTls スキーマ参照" Collapse section "B.117. KafkaMirrorMakerTls スキーマ参照" B.117.1. trustedCertificates B.118. KafkaMirrorMakerProducerSpec スキーマ参照 Expand section "B.118. KafkaMirrorMakerProducerSpec スキーマ参照" Collapse section "B.118. KafkaMirrorMakerProducerSpec スキーマ参照" B.118.1. abortOnSendFailure B.118.2. 設定 B.119. KafkaMirrorMakerTemplate スキーマ参照 B.120. KafkaMirrorMakerStatus スキーマ参照 B.121. KafkaBridge スキーマ参照 B.122. KafkaBridgeSpec スキーマ参照 Expand section "B.122. KafkaBridgeSpec スキーマ参照" Collapse section "B.122. KafkaBridgeSpec スキーマ参照" B.122.1. ログ B.123. KafkaBridgeTls スキーマ参照 B.124. KafkaBridgeHttpConfig スキーマ参照 Expand section "B.124. KafkaBridgeHttpConfig スキーマ参照" Collapse section "B.124. KafkaBridgeHttpConfig スキーマ参照" B.124.1. cors B.125. KafkaBridgeHttpCors スキーマ参照 B.126. KafkaBridgeConsumerSpec スキーマ参照 B.127. KafkaBridgeProducerSpec スキーマ参照 B.128. KafkaBridgeTemplate スキーマ参照 B.129. KafkaBridgeStatus スキーマ参照 B.130. KafkaConnector スキーマ参照 B.131. KafkaConnectorSpec スキーマ参照 B.132. KafkaConnectorStatus スキーマ参照 B.133. KafkaMirrorMaker2 スキーマ参照 B.134. KafkaMirrorMaker2Spec スキーマ参照 B.135. KafkaMirrorMaker2ClusterSpec スキーマ参照 Expand section "B.135. KafkaMirrorMaker2ClusterSpec スキーマ参照" Collapse section "B.135. KafkaMirrorMaker2ClusterSpec スキーマ参照" B.135.1. 設定 B.136. KafkaMirrorMaker2Tls スキーマ参照 B.137. KafkaMirrorMaker2MirrorSpec スキーマ参照 B.138. KafkaMirrorMaker2ConnectorSpec スキーマ参照 B.139. KafkaMirrorMaker2Status スキーマ参照 B.140. KafkaRebalance スキーマ参照 B.141. KafkaRebalanceSpec スキーマ参照 B.142. KafkaRebalanceStatus スキーマ参照 C. サブスクリプションの使用 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 2020.Q4OpenShift Container Platform 上で AMQ Streams 1.6 を使用概要 本ガイドでは、Red Hat AMQ Streams をインストール、設定、および管理して、大規模なメッセージングネットワークを構築する方法を説明します。 Next