Sushant,
You are using kafka clients new consumer api. It looks like you want to
use high-level consumer api?. If so you need use following kafka core lib as
the dependency
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.2.1</version>
</dependency
More details on this page
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
--
Harsha
On June 21, 2015 at 8:02:01 AM, Shushant Arora (shushantaror...@gmail.com)
wrote:
which is the latest jar to be used for kafka java client.
As in
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.1</version>
</dependency>
In class org.apache.kafka.clients.consumer.KafkaConsumer
public Map<String, ConsumerRecords<K,V>> poll(long timeout) {
// TODO Auto-generated method stub
return null;
}
poll method returns null. I want to use a high level java consumer.
And why in org.apache.kafka.clients.consumer.ConsumerConfig configuration
is for
public static final String BOOTSTRAP_SERVERS_CONFIG = "bootstrap.servers";
not for zookeeper.connect ? Is in highlevel offsets are maintained by
zookeeper
then why broker address is required?
