Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5634
I'm closing this PR now, as it seems the overall agreement is that we want
to implement this differently, or at least not touch the Kafka connector code
any more now.---
