The new consumer wasn't implemented until 0.9.0.0. The API was sketched
out, but no implementation had been included yet.
-Ewen
On Tue, Feb 9, 2016 at 8:00 AM, Joe San <codeintheo...@gmail.com> wrote:
> Is this intentioal in the Kafka 0.8.2.0 version,
> org.apache.kafka.clients.consumer.KafkaConsumer, the method:
>
> public Map<String, ConsumerRecords<K, V>> poll(long timeout) {
> return null;
> }
>
> Which version of 0.8.x.x should I use so that I could do a
> consumer.poll(2000)?
>
--
Thanks,
Ewen
