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.---
