Apache KafkaServer 从 Java 创建记者答案

【问题标题】：Apache KafkaServer create reporters from JavaApache KafkaServer 从 Java 创建记者
【发布时间】：2017-10-29 21:03:50
【问题描述】：

跟进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？

【问题讨论】：

标签： java scala clojure apache-kafka

【解决方案1】：

我在create KafkaServer from Java 中给你的代码应该可以工作。我刚刚在 0.11.0.1 （您在另一个问题中提到的版本）中尝试过它，它工作正常。

完整的sn-p：

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));
    }
}

【讨论】：