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));
}
}
有关如何选择性地抑制指标的更多详细信息,请参阅 此处。