How could I use Kafka for offset management with the 0.8.2 version of Kafka`
On Tue, Feb 9, 2016 at 10:54 PM, Yifan Ying <nafan...@gmail.com> wrote: > Please check out consumer configs. > http://kafka.apache.org/082/documentation.html#consumerconfigs > > On Tue, Feb 9, 2016 at 1:16 PM, Joe San <codeintheo...@gmail.com> wrote: > > > Can I do automatic offset commit using the highlevel consumer? If so, > where > > is the offset being comitted? > > > > On Tue, Feb 9, 2016 at 10:13 PM, Ewen Cheslack-Postava < > e...@confluent.io> > > wrote: > > > > > 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 > > > > > > > > > -- > Yifan >
