Actually in 0.8.2.2 only kafkaproducer is fully implemented not
Kafkaconsumer.
Here is the implementation of kafkaconsumer poll method in 0.8.2.2.
@Override
public Map> poll(long timeout) {
// TODO Auto-generated method stub
return null;
}
KafkaConsumer will be releas
Note that I did work around this issue, by including the entire Kafka:
org.apache.kafka
kafka_2.10
0.8.2.2
dependency, and using the legacy Consumer API,
instead of the kafka-clients dependency:
org.apache.kafka
kafka-clients
0.8.2.2
Listed in the documentation:
htt
Hello!
I'm running into trouble using the latest Kafka client.
0.8.2.2 appears to be listed as a stable release on Maven Central:
http://mvnrepository.com/artifact/org.apache.kafka/kafka-clients
And it only includes the:
org.apache.kafka.clients.consumer.KafkaConsumer client
All the other C
