java - Apache KafkaServer 从 Java 创建记者

Question

跟进create `KafkaServer` from Java

我正在从 Java 创建一个 KafkaServer(确实是 Clojure，但是给定一个有效的 Java 示例，它很容易翻译)。

除了空序列之外，我无法传递任何内容。我如何在 Java 中编写与此行等效的内容？

https://github.com/apache/kafka/blob/cb674e5487f3f56647546b323dfe4fd45ccf0186/core/src/main/scala/kafka/server/KafkaServerStartable.scala#L27

val reporters = KafkaMetricsReporter.startReporters(new VerifiableProperties(serverProps))

或者，更好的是，是否有用于创建报告器的 Java/Clojure API？

Answer 1

我给你的代码create KafkaServer from Java应该管用。我刚刚在 0.11.0.1(您在另一个问题中提到的版本)中尝试过，效果很好。

完整片段:

package main;

import java.util.Properties;
import kafka.metrics.KafkaMetricsReporter;
import kafka.metrics.KafkaMetricsReporter$;
import kafka.utils.VerifiableProperties;
import scala.collection.*;

public class Reporters {

    public static void main(String[] args) {
        Properties props = new Properties();
        Seq<KafkaMetricsReporter> reporters = KafkaMetricsReporter$.MODULE$.startReporters(new VerifiableProperties(props));
    }
}