Kafka Streams 指标 - 重新平衡延迟和状态

Question

我正在使用 Spring Boot 和 Micrometer 构建 Kafka Streams 应用程序。我想知道如何收集/公开以下指标：

• 每个任务从重新平衡到运行所需的延迟。理想情况下，我想知道任何状态转换的延迟
• 每个任务的当前流状态
• 从应用程序启动时的主题恢复状态存储数据的延迟 - 我正在使用 RocksDB

这些指标似乎不是开箱即用的，或者至少我找不到它们......

我添加了Spring的

org.springframework.kafka.streams.KafkaStreamsMicrometerListener

如下：

    @Bean
    fun streamsBuilderConfigurer(
        meterRegistry: MeterRegistry
    ): StreamsBuilderFactoryBeanConfigurer =
        StreamsBuilderFactoryBeanConfigurer { factoryBean ->
            factoryBean.addListener(KafkaStreamsMicrometerListener(meterRegistry))
        }