Re: kafka offset commit

2016-06-06 Thread Devendra Tagare
greatly decreases if I use HDFS for storage ? >> >> Thank you very much. >> >> Regards, >> Raja. >> >> From: "hsy...@gmail.com" <hsy...@gmail.com> >> Reply-To: "users@apex.apache.org" <users@apex.apache.org> >>

Re: kafka offset commit

2016-06-06 Thread hsy...@gmail.com
apex.apache.org> > Date: Monday, June 6, 2016 at 6:42 PM > > To: "users@apex.apache.org" <users@apex.apache.org> > Subject: Re: kafka offset commit > > Hey Raja, > > For 0.8, you have to implement OffsetManager interface on your own. The > upd

Re: kafka offset commit

2016-06-06 Thread Raja . Aravapalli
sers@apex.apache.org<mailto:users@apex.apache.org>" <users@apex.apache.org<mailto:users@apex.apache.org>> Date: Monday, June 6, 2016 at 6:42 PM To: "users@apex.apache.org<mailto:users@apex.apache.org>" <users@apex.apache.org<mailto:users@apex.apache.org

Re: kafka offset commit

2016-06-06 Thread Raja . Aravapalli
t; Date: Monday, June 6, 2016 at 5:23 PM To: "users@apex.apache.org<mailto:users@apex.apache.org>" <users@apex.apache.org<mailto:users@apex.apache.org>> Subject: Re: kafka offset commit Hi Raja, Which Kafka version are you using? With the new 0.9 connector there is no

Re: kafka offset commit

2016-06-06 Thread Thomas Weise
Hi Raja, Which Kafka version are you using? With the new 0.9 connector there is no need for the offset manager: https://github.com/apache/apex-malhar/tree/master/kafka/src/main/java/org/apache/apex/malhar/kafka Thanks, Thomas On Mon, Jun 6, 2016 at 3:06 PM, Raja.Aravapalli