从 SpringBoot 2.2.13 切换到 2.3.x - 2.6.x 中的任何一个时 我不再有以千分尺发布的 kafka 指标。
我没有使用 spring-kafka，只是手动创建 KafkaStreams 或 KafkaConsumer，但这适用于 2.2.x。添加 spring-kafka 依赖项没有帮助。有谁知道我必须做些什么才能找回这些？
【问题讨论】：
标签： java spring-boot apache-kafka micrometer
自 Spring Boot 2.3 起，Kafka 指标名称已更改。
kafka_consumer_records_consumed_total_records_total -> kafka_consumer_fetch_manager_records_consumed_total
kafka_consumer_records_lag_records -> kafka_consumer_fetch_manager_records_lag
kafka_consumer_records_lag_max_records -> kafka_consumer_fetch_manager_records_lag_max
kafka_consumer_fetch_latency_max_seconds -> kafka_consumer_fetch_manager_fetch_latency_max
kafka_consumer_bytes_consumed_total_bytes_total -> kafka_consumer_fetch_manager_bytes_consumed_total
kafka_consumer_records_per_request_avg_records -> kafka_consumer_fetch_manager_records_per_request_avg
kafka_consumer_heartbeat_rate_heartbeats -> kafka_consumer_coordinator_heartbeat_rate
如果您有自定义的消费者工厂，请添加customizers.orderedStream().forEach(customizer -> customizer.customize(consumerFactory));
@Bean
public ConsumerFactory<Integer, String> customConsumerFactory(ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers) {
DefaultKafkaConsumerFactory<Integer, String> consumerFactory = new DefaultKafkaConsumerFactory<>(customConsumerConfigs());
customizers.orderedStream().forEach(customizer -> customizer.customize(consumerFactory));
return consumerFactory;
}
【讨论】：
spring-kafka 只是new KafkaConsumer(...) 或new KafkaStreams(...)。
我认为如果您手动创建这些组件，您应该手动注册它们，请参阅KafkaMetrics（我不确定这在 2.2.x 中是如何工作的）。您还可以在 KafkaMetricsAutoConfiguration 中查看 Spring Boot 是如何做到这一点的。
【讨论】：
KafkaMetricsAutoConfiguration，但没有在我的用例中使用它的示例。我最终确实使用了new KafkaStreamsMetrics(stream).bindTo(registry) 或new KafkaClientMetrics(consumer).bindTo(registry)，这似乎确实有效，但找到所有案例并手动添加它并不理想。