Kafka 指标

Kafka binder 模块公开了以下指标

spring.cloud.stream.binder.kafka.offset：此指标表示给定消费者组尚未从给定 binder 的主题中消费的消息数量。提供的指标基于 Micrometer 库。如果 Micrometer 在 classpath 中且应用未提供其他此类 bean，则 binder 会创建 KafkaBinderMetrics bean。此指标包含消费者组信息、主题以及已提交偏移量与主题最新偏移量的实际延迟。此指标对于向 PaaS 平台提供自动扩缩反馈特别有用。

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

通过在应用中提供以下组件，您可以排除 KafkaBinderMetrics 创建必要的基础设施（如消费者）并随后报告指标。

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

关于如何选择性抑制指标的更多详细信息可以在此处找到。