Kafka 指标
Kafka binder 模块暴露了以下指标:
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));
}
}
有关如何选择性抑制仪表的更多详细信息,请参阅此处。