Hi folks, I'd like to start a discussion thread about backporting some FLIP-27 Kafka source connector fixes to release-1.12. These fixes include some API changes and thus needs a public discussion.
The tickets in question are following: https://issues.apache.org/jira/browse/FLINK-20379 https://issues.apache.org/jira/browse/FLINK-20114 https://issues.apache.org/jira/browse/FLINK-21817 Without these fixes, the FLIP-27 Kafka source in release-1.12 is not really usable, and the API changes only affect the Kafka Source. So it seems breaking the API in this case is still worthwhile. It would be good to see what others think. Thanks, Jiangjie (Becket) Qin
