Confluent Telemetry Reporter¶
概要¶
Confluent Telemetry Reporter は、サービスに関するメタデータを Confluent にプッシュするために各 Confluent Platform サービス内で動作するプラグインです。Telemetry Reporter により、メタデータに基づく製品機能(Proactive Support など)が有効になります。データは HTTP を介して送信され、暗号化された接続が使用されます。
重要
- クラスターで Self-Balancing が有効になっていると、Telemetry Reporter が有効になり、Self-Balancing Clusters の要件としてデフォルトで実行されます。Self-Balancing アルゴリズムでは、Telemetry Reporter の内部トピック _confluent-telemetry-metrics から消費が行われます。
- クラスターで Self-Balancing が有効になっていない場合、
$CONFLUENT_HOME/etc/kafka/server.properties
のプロパティ設定confluent.reporters.telemetry.auto.enable=false
を使用して、Telemetry Reporter を完全に無効にすることができます。 confluent.telemetry.enabled
をfalse
に設定した場合、データは Confluent Cloud に送信されません。
利用可能なメトリクスのリストについては、「Telemetry Reporter のメトリクス」を参照してください。
インストール¶
Confluent Telemetry Reporter は、Confluent Platform のフルインストールの一部としてインストールされます。パッケージを個別にインストールする場合は、yum install confluent-telemetry
を使用して、Telemetry Reporter が確実にインストールされるようにします。
Confluent Cloud に対するテレメトリレポートの有効化¶
- 前提条件
- Confluent Cloud へのアクセス
- インターネット接続(直接またはプロキシ経由)
- Confluent Platform 6.0 以降
Confluent Cloud での認証のための Cloud API キー を作成します。その例を次に示します。
ccloud login
ccloud api-key create --resource cloud
注釈
"必ず" Cloud API キーを使用してください。Kafka と通信するために使用する Cluster API キーを使用すると、認証エラーになります。
Ansible Playbooks for Confluent Platform を使用する構成¶
Ansible Playbooks for Confluent Platform を使用して Confluent Platform のインストールを管理する場合は、以下の構成オーバーライドをすべての Confluent Platform ロールに追加し、変更をデプロイします。
telemetry_enabled: true
telemetry_api_key: <api-key>
telemetry_api_secret: <api-secret>
Confluent Operator 1.x を使用した構成¶
Confluent Operator を使用して Confluent Platform を管理する場合は、このセクションの説明に従ってテレメトリを有効にできます。
Operator 構成ファイル(
$VALUES_FILE
)で以下を設定して、グローバルレベルまたはコンポーネントレベルでテレメトリを有効にします。telemetry: enabled: true --- [1] secretRef: <confluent-telemetry-secret> --- [2] proxy: false --- [3]
- [1]
enabled: true
と設定して、テレメトリを有効にします。 - [2]
secretRef
を、キーtelemetry
を含む Kubernetes シークレットに設定します。下にある最後の手順の説明に従い、このシークレット(<confluent-telemetry-secret>
)を作成します。 - [3]
proxy: true
を設定し、認証済みの HTTP プロキシ経由でのテレメトリデータのルーティングを有効にします。proxy
をtrue
に設定した場合、telemetry.secretRef
のシークレットには、さらにプロキシ構成が含まれている必要があります。
- [1]
telemetry.txt
ファイルを作成し、そのファイルに以下を追加します。apiKey=<ccloud-api-key> apiSecret=<ccloud-api-secret>
上にある最初の手順で
telemetry.proxy: true
を設定した場合は、telemetry.txt
ファイルに以下を追加します。proxyUrl=<proxyUrl> proxyUsername=<username> proxyPassword=<password>
最初の手順([2])の
telemetry.secreteRef
で指定した名前で、Kubernetes シークレットを作成します。このセクションの例では、<confluent-telemetry-secret>
が使用されています。kubectl --namespace <namespace> create secret generic \ <confluent-telemetry-secret> \ --from-file=telemetry=<path>/telemetry.txt
カスタムデプロイメントの構成¶
Confluent Server 以外のすべての Confluent Platform コンポーネントの場合は、サービスの構成ファイルに以下の行を追加し、サービスを再開して新しい構成をデプロイすることにより、テレメトリレポートを有効にします。上記で生成されたキーおよびシークレットで、<API_KEY>
および <API_SECRET>
を置き換えます。
metric.reporters=io.confluent.telemetry.reporter.TelemetryReporter
confluent.telemetry.enabled=true
confluent.telemetry.api.key=<API_KEY>
confluent.telemetry.api.secret=<API_SECRET>
Confluent Server の場合、metric.reporters
の構成は不要です。以下の行を Confluent Server 構成ファイルに追加し、Confluent Server を再起動します。Confluent Server を再起動しない場合は、動的構成および kafka-config
CLI を使用して、これらの構成を追加することができます。
confluent.telemetry.enabled=true
confluent.telemetry.api.key=<API_KEY>
confluent.telemetry.api.secret=<API_SECRET>
プロキシの構成¶
Confluent Telemetry Reporter は、認証済みの HTTP プロキシ経由でのテレメトリデータのルーティングをサポートしています。これらの環境では、以下のパラメーターを設定することにより、プロキシ経由でテレメトリデータを送信します。
confluent.telemetry.proxy.url=http://<proxy_server_ip>:<proxy_server_port>
confluent.telemetry.proxy.username=<proxy-username>
confluent.telemetry.proxy.password=<proxy-password>
送信データの内容およびデータの用途¶
お客様が特定の Confluent Platform コンポーネントに対して Confluent Telemetry Reporter を有効にした場合、Confluent は、その Confluent Platform コンポーネントに関するメトリクスを収集します。これには、ランタイムパフォーマンスのメトリクス、Kafka のバージョン、Confluent Platform のバージョン、該当する Confluent Platform コンポーネントの一意の識別子、Kafka クラスターの一意の識別子、お客様組織の一意の識別子が含まれます。データは暗号化された接続を使用して Confluent サーバーに送信されます(デフォルトでは 1 分 に 1 回)。結果として得られるデータは、Confluent が Proactive Support をお客様に提供し、Confluent 製品や Confluent サービスをメンテナンスおよび改善するために使用されます。このデータを送信するには、各 Confluent Platform コンポーネントで構成フラグを設定して、送信を有効にします。これらの構成フラグを削除すると、データの送信をいつでも停止することができます。
動的構成¶
注釈
現時点では、動的構成は Kafka ブローカーにのみ適用されます。
動的構成をクラスターに適用する方法については、「Kafka の動的構成」を参照してください。
再起動なしでのテレメトリの有効化¶
Confluent Server を使用している場合は、以下のコマンドを使用することにより、再起動なしで Telemetry Reporter を有効にすることができます。上記で生成されたキーおよびシークレットで、<API_KEY>
および <API_SECRET>
を置き換えます。
./bin/kafka-configs --bootstrap-server localhost:9092 --alter --entity-type brokers --entity-default --add-config confluent.telemetry.enabled=true,confluent.telemetry.api.key=<API_KEY>,confluent.telemetry.api.secret=<API_SECRET>
サポートされる動的構成プロパティ¶
confluent.telemetry.enabled
confluent.telemetry.api.key
confluent.telemetry.api.secret
confluent.telemetry.proxy.url
confluent.telemetry.proxy.username
confluent.telemetry.proxy.password