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>
>>
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
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
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
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