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.


---

Reply via email to