Kafka 指标
Kafka binder 模块暴露以下指标:
spring.cloud.stream.binder.kafka.offset: 该指标表示给定消费者组从给定绑定器的主题中尚未消费的消息数量。提供的指标基于 Micrometer 库。如果类路径上存在 Micrometer 且应用程序未提供其他此类 bean,绑定器将创建 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));
}
}
有关如何选择性抑制指标的更多详细信息,请参阅此处。