On Thu, Feb 1, 2018 at 1:29 AM, Sushil Ks <sushil...@gmail.com> wrote:
>
>> Hi,
>>Apologies for delay in my reply,
>>
>> @Raghu Angadi
>> This checkpoints 20 mins, as you mentioned before any
>> checkpoint is created and if the p
eckpoint, the pipeline could restart without any state,
>>> in which case KafkaIO would read from latest offset. There is probably some
>>> way to verify if pipeline is restarting from a checkpoint.
>>>
>>> On Sun, Jan 7, 2018 at 10:57 PM, Sushil Ks <sushil...@gmail.co
PM, "Reuven Lax" <re...@google.com> wrote:
> Do you set ENABLE_AUTO_COMMIT_CONFIG?
>
> On Sun, Jan 7, 2018 at 10:57 PM, Sushil Ks <sushil...@gmail.com> wrote:
>
>> HI Aljoscha,
>>The issue is let's say I consumed 100 elements in 5
&g
the rest 30
elements. Wanted to know if this is expected? In case if you still having
doubt let me know will share a code snippet.
Regards,
Sushil Ks
*bump*
On Dec 15, 2017 11:22 PM, "Lukasz Cwik" <lc...@google.com> wrote:
> +dev@beam.apache.org
>
> On Thu, Dec 14, 2017 at 11:27 PM, Sushil Ks <sushil...@gmail.com> wrote:
>
>> Hi Likasz,
>>I am not sure whether I can reprod
