Java編譯器找不到卡夫卡類

Question

我在使用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> 

Answer 1

你必須使用類似這樣的

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

kafka.utils.ZKStringSerializer是Scala的對象。要在java中使用scala對象，你必須像上面那樣使用。