13.2.111. KafkaBridgeSpec 模式参考

用于: KafkaBridge

KafkaBridgeSpec 模式属性的完整列表

配置 Kafka Bridge 集群。

配置选项与:

  • Kafka 集群 bootstrap 地址
  • 安全(加密、身份验证和授权)
  • 使用者配置
  • 制作者配置
  • HTTP 配置

13.2.111.1. logging

Kafka Bridge 有自己的可配置日志记录器:

  • logger.bridge
  • logger.<operation-id>

您可以替换 日志记录器中的 <operation-id> 。<operation-id> logger 为特定操作设置日志级别:

  • createConsumer
  • deleteConsumer
  • 订阅
  • 取消订阅
  • Poll
  • assign
  • commit
  • send
  • sendToPartition
  • seekToBeginning
  • seekToEnd
  • 寻道
  • healthy
  • Ready
  • OpenAPI

每个操作都按照 OpenAPI 规范定义,并且具有一个对应的 API 端点,该端点用于接收来自 HTTP 客户端的请求。您可以更改每个端点的日志级别,以创建关于传入和传出 HTTP 请求的精细日志信息。

每个日志记录器都必须 配置为 http.openapi.operation.<operation-id>。例如,为 发送 操作日志记录器配置日志级别意味着定义以下内容:

logger.send.name = http.openapi.operation.send
logger.send.level = DEBUG

Kafka Bridge 使用 Apache log4j2 日志记录器实施。日志记录器在 log4j2.properties 文件中定义,该文件具有 健康和 就绪 端点的以下默认配置:

logger.healthy.name = http.openapi.operation.healthy
logger.healthy.level = WARN
logger.ready.name = http.openapi.operation.ready
logger.ready.level = WARN

所有其他操作的日志级别默认设置为 INFO

使用 logging 属性来配置日志记录器和日志记录器级别。

您可以通过直接(内线)指定日志记录器和级别来设置日志级别,或使用自定义(外部)ConfigMap。如果使用 ConfigMap,则将 logging.valueFrom.configMapKeyRef.name 属性设置为包含外部日志记录配置的 ConfigMap 的名称。logging.valueFrom.configMapKeyRef.namelogging.valueFrom.configMapKeyRef.key 属性是必需的。如果未设置 名称或 密钥,则会使用默认日志记录。在 ConfigMap 中,日志配置使用 log4j.properties 进行 描述。有关日志级别的更多信息,请参阅 Apache 日志记录服务

此处我们会看到 内联 和外部 记录示例。

内联日志记录

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaBridge
spec:
  # ...
  logging:
    type: inline
    loggers:
      logger.bridge.level: "INFO"
      # enabling DEBUG just for send operation
      logger.send.name: "http.openapi.operation.send"
      logger.send.level: "DEBUG"
  # ...

外部日志记录

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaBridge
spec:
  # ...
  logging:
    type: external
    valueFrom:
      configMapKeyRef:
        name: customConfigMap
        key: bridge-logj42.properties
  # ...

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

如果使用 Cluster Operator 部署 Kafka Bridge,则会动态应用 Kafka Bridge 日志级别。

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

垃圾收集器(GC)

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