Java 编译器找不到 Kafka 类答案

【问题标题】：Java Compiler Cannot Find Kafka ClassJava 编译器找不到 Kafka 类
【发布时间】：2016-03-08 19:07:19
【问题描述】：

我在 Java 代码中使用此问题的最后一个答案时遇到问题。 Kafka: Get broker host from ZooKeeper

具体来说，它无法找到这一行的最后一个参数：

ZkClient client = new ZkClient("localhost:2181", 10000, kafka.utils.ZKStringSerializer);

我正在使用 Maven，如果重要的话，这些是 pom.xml 中的依赖项。

<dependencies>
        <dependency>
                <groupId>org.apache.kafka</groupId>
                <artifactId>kafka_2.11</artifactId>
                <version>0.8.2.2</version>
        </dependency>
        <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.7</version>
        </dependency>
</dependencies>

【问题讨论】：

您遇到编译时问题了吗？
@localhost999 是的，是编译时问题。

标签： java maven apache-kafka

【解决方案1】：

你必须这样使用

ZkClient client = new ZkClient("localhost:2181", Integer.MAX_VALUE,10000, kafka.utils.ZKStringSerializer$.MODULE$);

kafka.utils.ZKStringSerializer 是一个 Scala 对象。要在 java 中使用 scala 对象，您必须像上面那样使用。

【讨论】：

谢谢！有用！因为我还是 Scala 的新手，所以我永远也想不通。