[
https://issues.apache.org/jira/browse/FLINK-19152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199118#comment-17199118
]
Nawab Zada Asad iqbal commented on FLINK-19152:
-----------------------------------------------
[~aljoscha] , there is functionality like ratelimiting
{{FlinkConnectorRateLimiter rateLimiter}} which is only available in
{{FlinkKafkaConsumer010}} but not in the modern form {{FlinkKafkaConsumer}}. Is
there a design discussion regarding why this is discontinued? What is the
proposed alternative? I would like to use ratelimiting so that my sink target
(e.g. elastic search index) is not overwhlemed by the flink consumer.
> Remove Kafka 0.10.x and 0.11.x connectors
> -----------------------------------------
>
> Key: FLINK-19152
> URL: https://issues.apache.org/jira/browse/FLINK-19152
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: Aljoscha Krettek
> Assignee: Aljoscha Krettek
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.12.0
>
>
> Please see the ML thread for details:
> https://lists.apache.org/thread.html/r6d5c44e88d2d0fa187df6093694d6ad40c08561492c55b826b7231e7%40%3Cdev.flink.apache.org%3E
> In short, 0.10.x and 0.11.x are very old and you can use the "modern" Kafka
> connector to connect to older brokers/clusters. Plus, if push comes to shove,
> users can use the code from 1.11 and compile it against a newer Flink release.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
