使用 Spring-kafka 在 GC/消费者重新平衡时清理 Kafka Metric 计量器

Posted 2023-02-16

【中文标题】使用 Spring-kafka 在 GC/消费者重新平衡时清理 Kafka Metric 计量器

【英文标题】：Kafka Metric gauges being cleaned up on GC / consumer rebalance with Spring-kafka

【发布时间】：2021-11-29 06:45:30

【问题描述】：

我在我的一个应用程序中使用带有 spring-kafka 的 Spring cloud Stream，似乎每当有消费者重新平衡或 GC 时，kafka 消费者滞后量表都会由于弱引用而被垃圾收集，因此返回 NaN。

我看到有人在这里提到了类似的问题以及重现它的步骤。 https://issueexplorer.com/issue/micrometer-metrics/micrometer/2726

任何人都面临类似的问题以及任何解决方法？

我们想根据滞后量自动缩放我们的应用程序。

【参考方案1】：

这已在 micrometer-core 1.7.4 中修复。

【讨论】：

您的答案可以通过额外的支持信息得到改进。请edit 添加更多详细信息，例如引用或文档，以便其他人可以确认您的答案是正确的。你可以找到更多关于如何写好答案的信息in the help center。