此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.4

此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.4

可观测性 - 指标

您可以在下面找到此项目声明的所有指标的列表。

侦听器观察

对 Apache Kafka 侦听器的观察。

度量名称(由 convention class 定义)。键入spring.kafka.listenerKafkaListenerObservation$DefaultKafkaListenerObservationConventiontimer

度量名称(由 convention class 定义)。键入spring.kafka.listener.activeKafkaListenerObservation$DefaultKafkaListenerObservationConventionlong task timer

*.active 指标中可能缺少在开始观察后添加的 KeyValue。
Micrometer 内部用于 baseunit。但是,每个后端都决定了实际的 baseunit。(即 Prometheus 使用秒)nanoseconds

封闭类 的名称 。KafkaListenerObservation

表 1.低基数键

messaging.kafka.consumer.group (必填)

向使用者组发送消息。

messaging.operation (必填)

消息收发操作。

messaging.source.kind (必填)

消息源类型。

messaging.source.name (必填)

消息源名称。

messaging.system (必填)

消息系统。

spring.kafka.listener.id (必填)

侦听器 ID(或侦听器容器 Bean 名称)。

模板观察

KafkaTemplates 的观察。

度量名称(由 convention class 定义)。键入spring.kafka.templateKafkaTemplateObservation$DefaultKafkaTemplateObservationConventiontimer

度量名称(由 convention class 定义)。键入spring.kafka.template.activeKafkaTemplateObservation$DefaultKafkaTemplateObservationConventionlong task timer

*.active 指标中可能缺少在开始观察后添加的 KeyValue。
Micrometer 内部用于 baseunit。但是,每个后端都决定了实际的 baseunit。(即 Prometheus 使用秒)nanoseconds

封闭类 的名称 。KafkaTemplateObservation

表 2.低基数键

messaging.destination.kind (必填)

消息收发目标类型。

messaging.destination.name (必填)

消息收发目标名称。

messaging.operation (必填)

消息收发操作。

messaging.system (必填)

消息系统。

spring.kafka.template.name (必填)

模板的 Bean 名称。

*.active 指标中可能缺少在开始观察后添加的 KeyValue。
Micrometer 内部用于 baseunit。但是,每个后端都决定了实际的 baseunit。(即 Prometheus 使用秒)nanoseconds
表 1.低基数键

messaging.kafka.consumer.group (必填)

向使用者组发送消息。

messaging.operation (必填)

消息收发操作。

messaging.source.kind (必填)

消息源类型。

messaging.source.name (必填)

消息源名称。

messaging.system (必填)

消息系统。

spring.kafka.listener.id (必填)

侦听器 ID(或侦听器容器 Bean 名称)。

*.active 指标中可能缺少在开始观察后添加的 KeyValue。
Micrometer 内部用于 baseunit。但是,每个后端都决定了实际的 baseunit。(即 Prometheus 使用秒)nanoseconds
表 2.低基数键

messaging.destination.kind (必填)

消息收发目标类型。

messaging.destination.name (必填)

消息收发目标名称。

messaging.operation (必填)

消息收发操作。

messaging.system (必填)

消息系统。

spring.kafka.template.name (必填)

模板的 Bean 名称。

可观测性 - Span

您可以在下面找到此项目声明的所有 span 的列表。

侦听器观察跨度

对 Apache Kafka 侦听器的观察。

Span name (由 convention class 定义)。spring.kafka.listenerKafkaListenerObservation$DefaultKafkaListenerObservationConvention

封闭类 的名称 。KafkaListenerObservation

表 3.标签键

名字

描述

messaging.consumer.id (必填)

消息收发使用者 ID(使用者组和客户端 ID)。

messaging.kafka.client_id (必填)

消息收发客户端 ID。

messaging.kafka.consumer.group (必填)

向使用者组发送消息。

messaging.kafka.message.offset (必填)

消息收发消息偏移量。

messaging.kafka.source.partition (必填)

消息分区。

messaging.operation (必填)

消息收发操作。

messaging.source.kind (必填)

消息源类型。

messaging.source.name (必填)

消息源名称。

messaging.system (必填)

消息系统。

spring.kafka.listener.id (必填)

侦听器 ID(或侦听器容器 Bean 名称)。

模板观察跨度

KafkaTemplates 的观察。

Span name (由 convention class 定义)。spring.kafka.templateKafkaTemplateObservation$DefaultKafkaTemplateObservationConvention

封闭类 的名称 。KafkaTemplateObservation

表 4.标签键

名字

描述

messaging.destination.kind (必填)

消息收发目标类型。

messaging.destination.name (必填)

消息收发目标名称。

messaging.operation (必填)

消息收发操作。

messaging.system (必填)

消息系统。

spring.kafka.template.name (必填)

模板的 Bean 名称。

表 3.标签键

名字

描述

messaging.consumer.id (必填)

消息收发使用者 ID(使用者组和客户端 ID)。

messaging.kafka.client_id (必填)

消息收发客户端 ID。

messaging.kafka.consumer.group (必填)

向使用者组发送消息。

messaging.kafka.message.offset (必填)

消息收发消息偏移量。

messaging.kafka.source.partition (必填)

消息分区。

messaging.operation (必填)

消息收发操作。

messaging.source.kind (必填)

消息源类型。

messaging.source.name (必填)

消息源名称。

messaging.system (必填)

消息系统。

spring.kafka.listener.id (必填)

侦听器 ID(或侦听器容器 Bean 名称)。

表 4.标签键

名字

描述

messaging.destination.kind (必填)

消息收发目标类型。

messaging.destination.name (必填)

消息收发目标名称。

messaging.operation (必填)

消息收发操作。

messaging.system (必填)

消息系统。

spring.kafka.template.name (必填)

模板的 Bean 名称。

可观测性 - 约定

您可以在下面找到该项目声明的所有列表。GlobalObservationConventionObservationConvention

表 5.ObservationConvention 实现

ObservationConvention 类名

适用的 ObservationContext 类名

KafkaListenerObservation

KafkaRecordReceiverContext

KafkaListenerObservation.DefaultKafkaListenerObservationConvention

KafkaRecordReceiverContext

KafkaListenerObservationConvention

KafkaRecordReceiverContext

KafkaTemplateObservation

KafkaRecordSenderContext

KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention

KafkaRecordSenderContext

KafkaTemplateObservationConvention

KafkaRecordSenderContext

表 5.ObservationConvention 实现

ObservationConvention 类名

适用的 ObservationContext 类名

KafkaListenerObservation

KafkaRecordReceiverContext

KafkaListenerObservation.DefaultKafkaListenerObservationConvention

KafkaRecordReceiverContext

KafkaListenerObservationConvention

KafkaRecordReceiverContext

KafkaTemplateObservation

KafkaRecordSenderContext

KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention

KafkaRecordSenderContext

KafkaTemplateObservationConvention

KafkaRecordSenderContext


APP信息