Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4769 @tzulitai , confirm. because the `FlinkKafkaConsumer011` extend from `FlinkKafkaConsumer010` and `Kafka010Fetcher` extend from `Kafka09Fetcher`, for Kafka connector only need to fix Kafka08Fetcher and Kafka09Fetcher.
---