zhangminglei created FLINK-17919:
------------------------------------
Summary: KafkaConsumerThread should add ratelimiter functionality as well
Key: FLINK-17919
URL:
https://issues.apache.org/jira/browse/FLINK-17919 Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Reporter: zhangminglei
Currently, {{KafkaConsumerThread}} within {{flink-connector-kafka-09}} has the ability of rateLimiter. However, under {{flink-connector-kafka}} does not own it. I would suggest we can add it as well if we could.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)