B.80.2. logging
Kafka Connect(以及支持 Source2Image 的 Kafka Connect)具有自己的可配置日志记录器:
-
connect.root.logger.level
-
log4j.logger.org.reflections
根据运行的 Kafka Connect 插件,还会添加更多日志记录器。
使用 curl 请求获取从任何 Kafka 代理 pod 运行的 Kafka Connect loggers 的完整列表:
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 日志记录服务。
此处我们会看到 内联
和外部
记录示例。
内联日志记录
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 数量。 |
整数 | |
version | Kafka Connect 版本。默认值为 2.6.0。请参阅用户文档以了解升级或降级版本所需的流程。 |
字符串 | |
镜像 | 容器集的 docker 镜像。 |
字符串 | |
bootstrapServers | 引导服务器以进行连接。这应该以逗号分隔的 <hostname>: ›<port> 对列表指定。 |
字符串 | |
tls | TLS 配置。 |
身份验证 |
Kafka Connect 的身份验证配置.这个类型取决于给定对象中的 |
| |
config | Kafka Connect 配置。无法设置带有以下前缀的属性:ssl.、sasl.、security.、listeners、plugin.path、re.、bootstrap.servers、consumer.interceptor.classes、producer.interceptor.classes(除:ssl.endpoint.identification.algorithm 除外) SSL.cipher.suites、ssl.protocol、ssl.enabled.protocols。 |
map | |
资源 | CPU 和内存资源以及请求的初始资源的最大限值。请参阅 内核/v1 资源要求的外部文档。 |
livenessProbe | Pod 存活度检查. |
readinessProbe | Pod 就绪度检查。 |
jvmOptions | 容器集的 JVM 选项. |
关联性 |
属性 |
容限(tolerations) |
属性 |
容限 数组 | |
logging |
Kafka Connect 的日志配置.类型取决于给定对象中的 |
metrics | Prometheus JMX 导出器配置.有关此配置结构的详情,请查看 https://github.com/prometheus/jmx_exporter。 |
map | |
tracing |
Kafka Connect 中的追踪配置。类型取决于给定对象中 |
模板 |
Kafka Connect 和 Kafka Connect S2I 资源的模板。该模板允许用户指定如何生成 |
externalConfiguration | 将数据从 Secret 或 ConfigMap 传递给 Kafka Connect Pod,并使用它们来配置连接器。 |
clientRackInitImage |
用于初始化 |
字符串 | |
rack | 配置节点标签,该标签将用作 client.rack consumer 配置。 |