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/

curl -s http://<connect-cluster-name>-connect-api:8083/admin/loggers/

Copy to Clipboard

Toggle word wrap

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: inline
    loggers:
      connect.root.logger.level: "INFO"
  # ...

Copy to Clipboard

Toggle word wrap

外部日志记录

apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
spec:
  # ...
  logging:
    type: external
    name: customConfigMap
  # ...

apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
spec:
  # ...
  logging:
    type: external
    name: customConfigMap
  # ...

Copy to Clipboard

Toggle word wrap

任何未配置可用的日志记录器将其级别设置为 OFF。

如果使用 Cluster Operator 部署 Kafka Connect，则会动态地更改到 Kafka Connect 日志记录级别。

如果使用外部日志记录，当日志附加程序被更改时会触发滚动更新。

垃圾收集器(GC)

也可以使用 jvmOptions 属性来启用（或禁用）垃圾收集器日志记录。

Expand

属性	描述
replicas	Kafka Connect 组中的 pod 数量。
整数	Kafka Connect 组中的 pod 数量。
version	Kafka Connect 版本。默认值为 2.6.0。请参阅用户文档以了解升级或降级版本所需的流程。
字符串	Kafka Connect 版本。默认值为 2.6.0。请参阅用户文档以了解升级或降级版本所需的流程。
镜像	容器集的 docker 镜像。
字符串	容器集的 docker 镜像。
bootstrapServers	引导服务器以进行连接。这应该以逗号分隔的 <hostname>: ›<port> 对列表指定。
字符串	引导服务器以进行连接。这应该以逗号分隔的 <hostname>: ›<port> 对列表指定。
tls	TLS 配置。
`KafkaConnectTls`	TLS 配置。
身份验证	Kafka Connect 的身份验证配置.这个类型取决于给定对象中的 `authentication.type` 属性的值，必须是 [tls, scram-sha-512, plain, oauth] 中的一个。
`KafkaClientAuthenticationTls`, `KafkaClientAuthenticationScramSha512`, `KafkaClientAuthenticationPlain`, `KafkaClientAuthenticationOAuth`
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 资源要求的外部文档。
ResourceRequirements	CPU 和内存资源以及请求的初始资源的最大限值。请参阅内核/v1 资源要求的外部文档。
livenessProbe	Pod 存活度检查.
`probe`	Pod 存活度检查.
readinessProbe	Pod 就绪度检查。
`probe`	Pod 就绪度检查。
jvmOptions	容器集的 JVM 选项.
`JvmOptions`	容器集的 JVM 选项.
关联性	属性 `关联性` 已弃用。现在，这个功能应该在路径 `spec.template.pod.affinity` 中配置。pod 的关联性规则。请参阅有关内核/v1 关联性的外部文档.
关联性
容限（tolerations）	属性 `容限` 已弃用。现在应该在路径 `spec.template.pod.tolerations` 中配置这个功能。pod 的容限。请参阅内核/v1 容限的外部文档。
容限数组
logging	Kafka Connect 的日志配置.类型取决于给定对象中的 `logging.type` 属性的值，它必须是 [inline, external] 之一。
`InlineLogging`, `ExternalLogging`
metrics	Prometheus JMX 导出器配置.有关此配置结构的详情，请查看 https://github.com/prometheus/jmx_exporter。
map
tracing	Kafka Connect 中的追踪配置。类型取决于给定对象中 `tracing.type` 属性的值，它必须是 [jaeger] 之一。
`JaegerTracing`
模板	Kafka Connect 和 Kafka Connect S2I 资源的模板。该模板允许用户指定如何生成 `Deployment`、`Pod` 和 `Service`。
`KafkaConnectTemplate`
externalConfiguration	将数据从 Secret 或 ConfigMap 传递给 Kafka Connect Pod，并使用它们来配置连接器。
`ExternalConfiguration`	将数据从 Secret 或 ConfigMap 传递给 Kafka Connect Pod，并使用它们来配置连接器。
clientRackInitImage	用于初始化 `client.rack` 的 init 容器的镜像。
字符串	用于初始化 `client.rack` 的 init 容器的镜像。
rack	配置节点标签，该标签将用作 client.rack consumer 配置。
`rack`	配置节点标签，该标签将用作 client.rack consumer 配置。

返回顶部

B.80.2. logging

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links