重要

このページの日本語コンテンツは古くなっている可能性があります。最新の英語版コンテンツをご覧になるには、こちらをクリックしてください。

Control Center を Confluent Cloud に接続する

Confluent Control Center では、Confluent Cloud で実行されているデータストリームをモニタリングできます。

このように構成するには、プロデューサーとコンシューマーのインターセプターを有効にし、Control Center から Confluent Cloud にデータを書き込めるようにする必要があります。

ちなみに

Docker を使用して Control Center を Confluent Cloud に接続する例については、こちらの例 を参照してください。

前提条件
  • Confluent Cloud へのアクセス。
  • Confluent CLI
  • Confluent Cloud ユーザーの場合には、Control Center を使用するための追加の契約プランが必要です。使用量をコミットした Confluent Cloud ユーザーの場合は、Control Center の契約プランはデフォルトで組み込まれています。

基本的な構成手順は以下のとおりです。

  1. Confluent Cloud に接続するための API キーとシークレットを作成します。詳しくは、「ステップ 5: サービスアカウントおよび API キーとシークレットのペアの作成」を参照してください。

  2. Control Center をインストールするマシンから Confluent Cloud にアクセスできることを確認します。

    • confluent kafka topic list を使用して接続を確認します。
    • マシンから生成および消費を試します。
  3. ドキュメント を使用して Control Center をインストールします。

  4. Confluent Cloud の具体的な設定で Control Center を構成します。有効な最小構成を以下に示します。これらの設定は標準的な Confluent Cloud 構成とは異なります。使用している Confluent Cloud クラスターに合わせて bootstrap.serversconfluent.controlcenter.streams.sasl.jaas.config をカスタマイズします。

    bootstrap.servers=<cloud-bootstrap-servers>
    confluent.controlcenter.streams.security.protocol=SASL_SSL
    confluent.controlcenter.streams.sasl.mechanism=PLAIN
    confluent.controlcenter.streams.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
      username="<api-key>" \
      password="<api-secret>";
    confluent.metrics.topic.max.message.bytes=8388608
    confluent.controlcenter.streams.ssl.endpoint.identification.algorithm=https
    

    重要

    confluent.metrics.topic.max.message.bytes プロパティは 8388608 に設定する必要があります。詳細については、「Control Center から Confluent Cloud に接続できない」を参照してください。

  5. ドキュメント に従ってデータストリームインターセプターを構成します。追加する必要があるセキュリティ構成は次のとおりです。

    confluent.monitoring.interceptor.security.protocol=SASL_SSL
    confluent.monitoring.interceptor.sasl.mechanism=PLAIN
    confluent.monitoring.interceptor.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<api-key>" password="<api-secret>";
    confluent.monitoring.interceptor.ssl.endpoint.identification.algorithm=https
    
  6. (オプション)GitHub の ccloud/examples/template_delta_configs にある control-center-ccloud.delta の例に沿って Confluent Cloud スキーマレジストリ の構成を追加します。

    # Confluent Schema Registry configuration for Confluent Control Center
    confluent.controlcenter.schema.registry.basic.auth.credentials.source=USER_INFO
    confluent.controlcenter.schema.registry.basic.auth.user.info=<SCHEMA_REGISTRY_API_KEY>:<SCHEMA_REGISTRY_API_SECRET>
    confluent.controlcenter.schema.registry.url=https://<SCHEMA_REGISTRY_ENDPOINT>:443
    

    ちなみに

    The schema.registry.url for Control Center is specified using an HTTPS protocol prefix which requires an explicit 443 port, as shown in the above example.

Control Center の起動時に作成されるトピックの例を以下に示します。

 confluent kafka topic list
_confluent-controlcenter-4-0-0-1-KSTREAM-OUTERTHIS-0000000095-store-changelog
_confluent-controlcenter-4-0-0-1-AlertHistoryStore-changelog
_confluent-controlcenter-4-0-0-1-MonitoringStream-ONE_MINUTE-changelog
_confluent-controlcenter-4-0-0-1-aggregatedTopicPartitionTableWindows-THREE_HOURS-changelog
_confluent-controlcenter-4-0-0-1-aggregatedTopicPartitionTableWindows-ONE_MINUTE-changelog
_confluent-controlcenter-4-0-0-1-error-topic
_confluent-controlcenter-4-0-0-1-cluster-rekey
_confluent-controlcenter-4-0-0-1-MonitoringTriggerStore-changelog
_confluent-controlcenter-4-0-0-1-actual-group-consumption-rekey
_confluent-controlcenter-4-0-0-1-Group-ONE_MINUTE-changelog
_confluent-controlcenter-4-0-0-1-expected-group-consumption-rekey
_confluent-controlcenter-4-0-0-1-monitoring-message-rekey
_confluent-controlcenter-4-0-0-1-MetricsAggregateStore-changelog
_confluent-metrics
_confluent-controlcenter-4-0-0-1-Group-THREE_HOURS-changelog
_confluent-controlcenter-4-0-0-1-group-stream-extension-rekey
_confluent-controlcenter-4-0-0-1-group-aggregate-topic-ONE_MINUTE
_confluent-controlcenter-4-0-0-1-MonitoringMessageAggregatorWindows-THREE_HOURS-changelog
_confluent-controlcenter-4-0-0-1-MonitoringMessageAggregatorWindows-ONE_MINUTE-changelog
_confluent-controlcenter-4-0-0-1-group-aggregate-topic-THREE_HOURS-changelog
_confluent-controlcenter-4-0-0-1-monitoring-trigger-event-rekey
_confluent-controlcenter-4-0-0-1-TriggerActionsStore-changelog
_confluent-controlcenter-4-0-0-1-aggregate-topic-partition-changelog
_confluent-command
_confluent-controlcenter-4-0-0-1-TriggerEventsStore-changelog
_confluent-controlcenter-4-0-0-1-MonitoringVerifierStore-changelog
_confluent-controlcenter-4-0-0-1-metrics-trigger-measurement-rekey
_confluent-controlcenter-4-0-0-1-MetricsAggregateStore-repartition
_confluent-controlcenter-4-0-0-1-monitoring-aggregate-rekey-changelog
_confluent-controlcenter-4-0-0-1-aggregate-topic-partition
_confluent-controlcenter-4-0-0-1-monitoring-aggregate-rekey
_confluent-controlcenter-4-0-0-1-group-aggregate-topic-ONE_MINUTE-changelog
_confluent-monitoring
_confluent-controlcenter-4-0-0-1-MonitoringStream-THREE_HOURS-changelog
_confluent-controlcenter-4-0-0-1-KSTREAM-OUTEROTHER-0000000096-store-chang

制限

  • Control Center には、システム正常性に関する詳細情報は表示されません。Confluent Cloud は Confluent Metrics Reporter の計装機能を Confluent Cloud の外部に提供しないからです。Confluent Platform はシステムとブローカーの正常性を内部でモニタリングし、そのモニタリングに基づいてアクションを実行します。Control Center の インフラストラクチャ軽減モード を有効にすることをお勧めします。

  • Confluent Cloud でホストされ、Control Center に表示されるトピックは、Topics detail ページでは AvailabilityOffsetSize の各値が表示されません。この場合、これらのフィールドには 0 が表示されます。

  • Control Center は、データを保管するために Apache Kafka® クラスターを必要とします。Control Center は、パーティション制限にカウントされるデータストレージとデータスループットのためのパーティションを Confluent Cloud 内に作成します。

  • Control Center クラスターが Confluent Cloud にブートストラップされている場合、そのクラスターで使用できるメトリクスはありません。そのため、メトリクスアラートは機能しません。ただし、コンシューマーラグおよびクラスターのアップ/ダウンのアラートは、想定どおり機能します。

  • Control Center に以下の警告がログに記録されますが、無視できます。

    WARN broker=15 is not instrumented with ConfluentMetricsReporter (io.confluent.controlcenter.util.HealthCheck)elog
    _confluent-controlcenter-4-0-0-1-group-aggregate-topic-THREE_HOURS
    

おすすめの記事

  • Control Center の詳細については、「Confluent Control Center」を参照してください。
  • セルフホストから Confluent Cloud のハイブリッド Apache Kafka® クラスターの実例を表示するには、「Confluent Cloud デモ」を参照してください。
  • Confluent Cloud に接続する Confluent Platform のすべてのコンポーネントとクライアントの構成例については、コンポーネントのテンプレート例 を参照してください。
  • Confluent Cloud デモで使用されているすべてのコードを確認するには、Confluent Cloud デモの例 を参照してください。