问题描述
Flink-kafka-consumer有两种类型的消费者，例如：
这两个使用者层次结构都扩展相同的FlinkKafkaConsumerBase类。我想知道维护编号的类背后的设计决策是什么？我们什么时候应该使用其中一个？
我注意到带有数字后缀的类具有更多功能（例如，速率限制）。
编辑：（由于在master分支中删除了此文件，因此以下链接已停止工作）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java#L77
解决方法
版本化的Kafka使用者（和生产者）是针对那些版本的Kafka客户端构建的，旨在与每个特定版本的Kafka一起使用。未版本化的连接器FlinkKafkaConsumer和FlinkKafkaProducer使用通用客户端库构建，并且与自0.10开始的所有版本的Kafka兼容。
请注意，在Flink 1.11中删除了Kafka 0.8和0.9的版本化使用者和生产者，而在Flink 1.12（https://issues.apache.org/jira/browse/FLINK-19152）中则删除了0.10和0.11版本。
编辑：
在某些情况下，仅允许来自水槽的背压来节流水源就足够了。但是在其他情况下（例如多个来源），效果可能不够好。
您将在http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-Rate-Limit-in-FlinkConsumer-td36417.html上找到有关此问题的讨论以及进行自己的速率限制的代码。