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));
	}
}

關於如何選擇性抑制指標的更多詳細資訊可以在此處找到。