lindong28 edited a comment on pull request #15051: URL: https://github.com/apache/flink/pull/15051#issuecomment-787771772
Based on the offline discussion with @becketqin, I am going to help fix `KafkaSource` related bugs. And I will rebase and submit code from https://github.com/apache/flink/pull/14303 and https://github.com/apache/flink/pull/14239. The code in this PR mostly comes from @becketqin's https://github.com/apache/flink/pull/14303. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
