On Sun, Nov 6, 2016 at 4:31 AM, Demin Alexey <[email protected]> wrote:
> This is bug or incorrect using API from my side? This is a bug in KafkaIO. It should advance the watermark when there are no messages to read. https://issues.apache.org/jira/browse/BEAM-591 I want to fix it, but may not get to it until Thanksgiving, will see.
