B.80.2. logging
Kafka Connect (および Source2Image サポートのある Kafka Connect) には独自の設定可能なロガーがあります。
-
connect.root.logger.level -
log4j.logger.org.reflections
実行中の Kafka Connect プラグインに応じて、さらにロガーが追加されます。
curl リクエストを使用して、Kafka ブローカー Pod から稼働している Kafka Connect ロガーの完全リストを取得します。
curl -s http://<connect-cluster-name>-connect-api:8083/admin/loggers/
Kafka Connect では Apache log4j ロガー実装が使用されます。
logging プロパティーを使用してロガーおよびロガーレベルを設定します。
ログレベルを設定するには、ロガーとレベルを直接指定 (インライン) するか、またはカスタム (外部) ConfigMap を使用します。ConfigMap を使用する場合、logging.name プロパティーを外部ロギング設定が含まれる ConfigMap の名前に設定します。ConfigMap 内では、ロギング設定は log4j.properties を使用して記述されます。ログレベルの詳細は、「Apache logging services」を参照してください。
ここで、inline および external ロギングの例を示します。
inline ロギング
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
spec:
# ...
logging:
type: inline
loggers:
connect.root.logger.level: "INFO"
# ...
外部ロギング
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
spec:
# ...
logging:
type: external
name: customConfigMap
# ...
設定されていない利用可能なロガーのレベルは OFF に設定されています。
Cluster Operator を使用して Kafka Connect がデプロイされた場合、Kafka Connect のロギングレベルの変更は動的に適用されます。
外部ロギングを使用する場合は、ロギングアペンダーが変更されるとローリングアップデートがトリガーされます。
ガベッジコレクター (GC)
ガベッジコレクターのロギングは jvmOptions プロパティーを使用して 有効（または無効）にすることもできます。
| プロパティー | 説明 |
|---|---|
| replicas | Kafka Connect グループの Pod 数。 |
| integer | |
| version | Kafka Connect のバージョン。デフォルトは 2.6.0 です。バージョンのアップグレードまたはダウングレードに必要なプロセスを理解するには、ユーザードキュメントを参照してください。 |
| string | |
| image | Pod の Docker イメージ。 |
| string | |
| bootstrapServers | 接続するブートストラップサーバー。これは <hostname>:<port> ペアのコンマ区切りリストとして指定する必要があります。 |
| string | |
| tls | TLS 設定。 |
| authentication |
Kafka Connect の認証設定。タイプは、指定のオブジェクト内の |
|
| |
| config | Kafka Connect の設定。次の接頭辞を持つプロパティーは設定できません: ssl.、sasl.、security.、listeners、plugin.path、rest.、bootstrap.servers、consumer.interceptor.classes、producer.interceptor.classes (ssl.endpoint.identification.algorithm、ssl.cipher.suites、ssl.protocol、ssl.enabled.protocols を除く) |
| map | |
| resources | CPU とメモリーリソースおよび要求された初期リソースの上限。外部のキュメント「core/v1 resourcerequirements」を参照してください。 |
| livenessProbe | Pod の liveness チェック。 |
| readinessProbe | Pod の readiness チェック。 |
| jvmOptions | Pod の JVM オプション。 |
| affinity |
|
| tolerations |
|
| Toleration array | |
| logging |
Kafka Connect のロギング設定。タイプは、指定のオブジェクト内の |
| metrics | Prometheus JMX エクスポーターの設定。この設定の構造に関する詳細は、https://github.com/prometheus/jmx_exporter を参照してください。 |
| map | |
| tracing |
Kafka Connect でのトレースの設定。タイプは、指定のオブジェクト内の |
| template |
Kafka Connect および Kafka Connect S2I リソースのテンプレート。ユーザーはテンプレートにより、 |
| externalConfiguration | Secret または ConfigMap から Kafka Connect Pod にデータを渡し、これを使用してコネクターを設定します。 |
| clientRackInitImage |
|
| string | |
| rack | client.rack コンシューマー設定として使用されるノードラベルの設定。 |
