Github user tzulitai commented on the issue:
    I see, so it is basically a quicker workaround for per-shard watermarks for 
the Kinesis Consumer.
    Since we discussed that we'll likely have a reworked consumer in 1.6 that 
hopefully includes per-shard watermarks, I'll agree to merge this temporary 
workaround change now for 1.5.


Reply via email to