由 Spring Boot Actuator 支持的 Kafka MetricsReporter

Question

我决定回到我在此处提到的将 Kafka Metrics 与 Spring Boot Actuator 集成的想法：

https://github.com/spring-projects/spring-boot/issues/6227

到目前为止，我有一个带有工作代码的单独“沙盒”项目，我想将其合并到 Spring Boot 中。现在我有点困惑。我的部分测试需要 powermock 来模拟 Kafka 的“超级安全”类：

package org.apache.kafka.common.metrics;

// some imports...

public final class KafkaMetric implements Metric {
    private MetricName metricName;
    private final Object lock;
    private final Time time;
    private final Measurable measurable;
    private MetricConfig config;

    KafkaMetric(Object lock, MetricName metricName, Measurable measurable, MetricConfig config, Time time) {
        this.metricName = metricName;
        this.lock = lock;
        this.measurable = measurable;
        this.config = config;
        this.time = time;
    }

    // some good code here, but no public constructor and the class is final... of course.

}

但是在 Spring Boot 中没有使用 powermock。

我该怎么办？

1. 在 spring-boot-dependencies 和 spring-boot-actuator 中添加最新的稳定 powermock。
2. 仅将最新的稳定 powermock 添加到 spring-boot-actuator - 让它成为一个隐藏的秘密助手。
3. 排除需要 powermock 的测试。
4. 忘掉 Kafka Metrics，它们又大又可怕，没有人愿意在我们友好的 Spring Boot Actuator 中使用它们。

Answer 1

在 cmets 中得到您的确认后，我只是在此处复制我的评论作为正确关闭问题的有效答案。

您可以尝试使用Metrics.addMetric() 创建KafkaMetric 实例，然后通过您的KafkaStatisticsProvider.metricChange() 对其做出反应，您将在测试前将其注册到Metrics 实例中。当然，而不是 Powermock。

我将在下周找时间为您的执行器项目做出贡献，以避免 Powermock。