flink 的 Kafka 连接器里,flink-connector-kafka_2.12-1.13.2.jar这个版本算是比较稳定的老熟人了,Scala 2.12 环境下用它还挺顺手的,兼容性好,不容易踩坑。

Flink 1.13.2版本的配套连接器,API 变化不大,用起来也比较舒服,尤其是在你想用DataStream API去消费 Kafka 数据的时候,响应也快,代码也简单,实战里挺高频的。

之前试过其他版本,比如 2.11-1.13.6 也还行,不过2.12在 Scala 生态里更常见,配合 Flink 的 SQL 支持也蛮好用的,是写 SQL 查询 Kafka 表时,基本无缝衔接。

对了,如果你是刚入门的,建议先看下Flink 1.13.2 的双语教程,讲得还挺清楚,顺便把 Flink 资源包和这个 jar 一起下了,省得环境不对搞半天。

如果你是 Kafka 的老用户,又打算接入 Flink 做流,这个 jar 蛮合适的,兼容 Kafka 2.x 系列,像 Kafka 2.12-1.0.0 这些版本都能配上,不用担心太多适配问题。

哦对了,用的时候注意下KafkaSourceFlinkKafkaConsumer这两个类的区别,前者是新版推荐的,后者老项目多见,都能用,但别混着来。

如果你正在搞流式 ETL 或实时 BI,用这个 JAR 搭 Flink 项目真的还蛮顺,踩坑少效率高,挺适合日常开发的。