Hi all, The PR that I've been iterating on w.r.t. Kafka ratelimiting — https://github.com/apache/flink/pull/7679 is now in a state where a lot of the rate limiting logic is generic and does not apply specifically to Kafka. I'd thus, like to move it to a module that is outside of the* flink-connector-kafka-0.9/. *Looking at some of the other common modules, it seems like org.apache.flink.api.java <https://github.com/lyft/flink/tree/master/flink-core/src/main/java/org/apache/flink/api/java> maybe a good option? Thoughts or suggestions?
Thanks, Lakshmi
