Kafka のモニター

Instana が収集するすべての Kafka メトリクスは、 Consumerグループの遅延およびConsumer/Producerのバイトレート/スロットリングメトリクスを除き、 Apache Kafka、 Cloudera Kafka、 Confluent Kafka のすべてのバージョンで利用可能です。 オープンソースの Apache Kafka を基盤とする IBM® Event Streams は、 IBM Event Streams 11.0.4 （ IBM Event Streams Operator 3.0.5 ）以降のバージョンでサポートされています。

以下の表は、最新のサポート対象バージョンとサポート方針を示しています：

サポートポリシーに関する詳細については、 「センサーのサポート戦略」 を参照してください。

「コンシューマー・グループ・ラグ」 メトリックは、以下のバージョンで使用可能です。

• Apache Kafka （Zookeeper 対応） 0.11.x.x から 3.9.0 までのバージョン
• Apache Kafka （KRaft版） 3.9.0 からのバージョン
• Cloudera Kafka 3.x.x から 4.1.x までのバージョン
• Confluent Kafka 3.3.x からのバージョン
• IBM Event Streams 11.0.4 （ IBM Event Streams Operator 3.0.5 ）以降のバージョン

「コンシューマー／プロデューサーのバイトレート／スロットリング」 メトリクスは、 Java Kafka のクライアントのみ、かつ以下のバージョンで利用可能です：

• Apache Kafka 1.1.x からのバージョン
• Cloudera Kafka バージョン 4.0.x から 4.1.x
• Confluent Kafka 4.1.x からのバージョン
• IBM Event Streams 11.0.4 （ IBM Event Streams Operator v3.0.5 ）以降のバージョン

Instana 以下の言語およびランタイムのクライアントサイドトレースに対応しています：

• Java
• Go
• Node.js
• .Net Core

Instana 監視およびコンシューマー遅延メトリクスの収集において、以下の Kafka セキュリティプロトコルをサポートしています：

• プレーンテキスト ：認証や暗号化なし（デフォルト）
• SSL ： SSL / TLS オプションでクライアント認証を伴う暗号化接続
• SASL_PLAINTEXT : プレーンテキスト接続を介したSASL認証（PLAINメカニズム）

次の例に示すように、agent configuration.yaml ファイル poll_rate 内のパラメータを使用して、 Instana が Kafka からデータやメトリクスを収集するためにポーリングを行う頻度を設定できます

com.instana.plugin.kafka:
  poll_rate: 1 # value is in seconds. Default value is 1 second.

Kafka ブローカーインスタンスが SSL セキュリティプロトコルを使用している場合は、以下の例に示すように、 Instana エージェントを設定して <agent_install_dir>/etc/instana/configuration.yaml 、コンシューマーの遅延メトリクスの収集を有効にしてください：

com.instana.plugin.kafka:
  sslTrustStore: '/path/to/truststore.jks'
  sslTrustStorePassword: 'kafkaTsPassword'
  sslKeyStore: '/path/to/sslKeyStoreFile.jks'
  sslKeyStorePassword: 'kafkaKsPassword'
 

Kafka ブローカーインスタンスで、PLAIN認証メカニズムを備えたSASL_PLAINTEXT セキュリティプロトコルを使用している場合は、以下の例に示すように、 Instana エージェントを設定して <agent_install_dir>/etc/instana/configuration.yaml 、コンシューマーの遅延メトリクスの収集を有効にしてください：

com.instana.plugin.kafka:
  saslUsername: 'kafkaUser'
  saslPassword: 'kafkaPassword'
 

キーが Java キーストア（JKS）形式であることを確認してください。 keytool を使用して鍵を作成してください。

Kafka で「 JMX 」認証が有効になっている場合、次の例に示すように、 JMX を認証 <agent_install_dir>/etc/instana/configuration.yaml するために、 Instana エージェントを設定する必要があります

com.instana.plugin.kafka:
  jmxUsername: ''
  jmxPassword: ''
  jmxPort: '' # default jmx port is 1099
 

Instana のトレーサーで使用される Kafka トレース相関ヘッダーの形式を設定できます。 詳細については、 「 Kafka のトレース相関ヘッダーの設定」 を参照してください。

Kafka ノードを設定するには、以下の情報が必要です：

• バージョン
• Zookeeper Connects（Zookeeperモードの場合）またはController Quorum Voters（KRaftモードの場合）
• プロセス ID
• ノード ID
• トピック数/パーティション数

次の表は、パフォーマンス指標の詳細を示しています：

Kafka クラスタを設定するには、以下の情報が必要です：

• クラスター名
• Zookeeper
• ノード (名前、バージョン)
• トピック数/パーティション数

次の表は、パフォーマンス指標の詳細を示しています：

各センサーについて、正常状態のシグネチャをまとめたナレッジベースが、受信したメトリクスに対して継続的に照合され、ユーザーへの影響度に応じて問題やインシデントとして通知されます。

組み込みイベントは、エンティティのヘルスシグネチャに異常が検出されたことを受けて課題やインシデントをトリガーし、 カスタムイベントは、任意のエンティティの個別のメトリクスのしきい値に基づいて課題やインシデントをトリガーします。

Kafka のノードおよびクラスターの組み込みイベントに関する詳細については、 「組み込みイベントのリファレンス」 を参照してください。

監視対象の種類： kafka_ssl_not_configured

SSL の設定に関する問題を解決し、 Kafka の SSL のトラストストアの保存場所とパスワードを設定するには、 SSL / TLS Support を参照してください。

監視対象の種類： kafka_ssl_client_not_configured

SSL のクライアント認証に関する問題を解決し、 Kafka の SSL クライアント認証（キーストアの場所とパスワード）を設定するには、 SSL / TLS Support を参照してください。

監視対象の種類： kafka_invalid_jmx_credentials

JMX の認証に関する問題を解決し、 JMX の認証情報を設定するには、 JMX の「認証のサポート」 を参照してください。