Kafka 指标

Kafka 绑定器模块公开了以下指标

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

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

您可以通过在应用程序中提供以下组件来排除 KafkaBinderMetrics 创建必要的基础设施(如消费者)然后报告指标。

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

有关如何选择性地抑制指标的更多详细信息,请参阅 此处