If you are working against 0.8.2 brokers and cannot update, you'll have to
use the old consumer API for now. There are two parts to it, but you
probably want the high level consumer, documented here:
http://kafka.apache.org/documentation.html#highlevelconsumerapi
-Ewen
On Tue, Feb 9, 2016 at 12:36 PM, Joe San <codeintheo...@gmail.com> wrote:
> Could anyone point me to an older version of the consumer client that I
> could use to run against the 0.8.2 version of Kafka?
>
> On Tue, Feb 9, 2016 at 6:57 PM, Ewen Cheslack-Postava <e...@confluent.io>
> wrote:
>
> > 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
> >
>
--
Thanks,
Ewen
