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?
