此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4spring-doc.cadn.net.cn

Kafka 指标

Kafka Binder 模块公开了以下指标:spring-doc.cadn.net.cn

spring.cloud.stream.binder.kafka.offset:此指标表示给定使用者组尚未从给定 Binder 的主题中使用多少条消息。 提供的指标基于 Micrometer 库。 Binder 会创建KafkaBinderMetrics如果 Micrometer 在 Classpath 上并且应用程序没有提供其他此类 bean,则为 bean。 该指标包含使用者组信息、主题以及已提交偏移量与主题上最新偏移量的实际滞后。 此指标对于向 PaaS 平台提供自动扩展反馈特别有用。spring-doc.cadn.net.cn

可以通过在spring.cloud.stream.kafka.binder.metricsNamespace 请参阅 Kafka Binder Properties 部分以了解更多信息。spring-doc.cadn.net.cn

您可以排除KafkaBinderMetrics从创建必要的基础设施(如使用者),然后通过在应用程序中提供以下组件来报告指标。spring-doc.cadn.net.cn

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

有关如何选择性地抑制仪表的更多详细信息,请参阅此处spring-doc.cadn.net.cn