Java Compiler Cannot Find Kafka Class

Question

I'm having problem using the last answer of this question in my Java code. Kafka: Get broker host from ZooKeeper

Specifically, it fails finding the last argument on this line:

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

I'm using Maven and these are the dependencies in the pom.xml if it matters.

<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>

Did you get a compile time issue?

Omkar Puttagunta
– Omkar Puttagunta

2015-12-04 06:07:27 +00:00
Commented Dec 4, 2015 at 6:07 — Omkar Puttagunta
– Omkar Puttagunta, Commented Dec 4, 2015 at 6:07
@localhost999 Yes, it's compile time issue.

shinkou
– shinkou

2015-12-04 14:24:11 +00:00
Commented Dec 4, 2015 at 14:24 — shinkou
– shinkou, Commented Dec 4, 2015 at 14:24

sreejith · Accepted Answer · 2015-12-04 06:44:58Z

2

You have to use like this

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

kafka.utils.ZKStringSerializer is a scala object. To use scala object in java you have to use like above.

answered Dec 4, 2015 at 6:44

sreejith

7255 silver badges21 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

shinkou Over a year ago

Thanks! It works! I would have never figured that out since I'm still a newbie in Scala.

Collectives™ on Stack Overflow

Java Compiler Cannot Find Kafka Class

1 Answer 1

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related