Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4928
@tzulitai please check the details in the ticket:
https://issues.apache.org/jira/browse/FLINK-7732
I have changed the approach as we discussed and now we filtering out
happens just before committing offsets.---
