Kafka 指标

Kafka 绑定器模块暴露以下指标:

spring.cloud.stream.binder.kafka.offset:此指标表示给定消费者组尚未从给定绑定器主题消费的消息数量。 所提供的指标基于 Micrometer 库。 如果 Micrometer 位于类路径中,并且应用程序未提供其他此类 bean,则绑定器会创建 KafkaBinderMetrics bean。 该指标包含消费者组信息、主题以及与主题上最新偏移量相比的提交偏移量中的实际滞后。 此指标对于向 PaaS 平台提供自动伸缩反馈特别有用。

可以通过在 spring.cloud.stream.kafka.binder.metrics 命名空间中设置属性来配置指标收集行为, 有关更多信息,请参阅 kafka-binder-properties

您可以通过在应用程序中提供以下组件来排除 KafkaBinderMetrics 创建必要的 инфраструктура(例如消费者)并报告指标。

@Component
class NoOpBindingMeters {
	NoOpBindingMeters(MeterRegistry registry) {
		registry.config().meterFilter(
				MeterFilter.denyNameStartsWith(KafkaBinderMetrics.OFFSET_LAG_METRIC_NAME));
	}
}

有关如何选择性抑制计量器的更多详细信息,请参阅 此处