重要
このページの日本語コンテンツは古くなっている可能性があります。最新の英語版コンテンツをご覧になるには、こちらをクリックしてください。
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 の契約プランはデフォルトで組み込まれています。
基本的な構成手順は以下のとおりです。
Confluent Cloud に接続するための API キーとシークレットを作成します。詳しくは、「ステップ 5: サービスアカウントおよび API キーとシークレットのペアの作成」を参照してください。
Control Center をインストールするマシンから Confluent Cloud にアクセスできることを確認します。
confluent kafka topic list
を使用して接続を確認します。- マシンから生成および消費を試します。
ドキュメント を使用して Control Center をインストールします。
Confluent Cloud の具体的な設定で Control Center を構成します。有効な最小構成を以下に示します。これらの設定は標準的な Confluent Cloud 構成とは異なります。使用している Confluent Cloud クラスターに合わせて
bootstrap.servers
とconfluent.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 に接続できない」を参照してください。ドキュメント に従ってデータストリームインターセプターを構成します。追加する必要があるセキュリティ構成は次のとおりです。
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
(オプション)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 explicit443
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 ページでは Availability、Offset、Size の各値が表示されません。この場合、これらのフィールドには 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 デモの例 を参照してください。