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)