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 这些版本都能配上,不用担心太多适配问题。
哦对了,用的时候注意下KafkaSource
和FlinkKafkaConsumer
这两个类的区别,前者是新版推荐的,后者老项目多见,都能用,但别混着来。
如果你正在搞流式 ETL 或实时 BI,用这个 JAR 搭 Flink 项目真的还蛮顺,踩坑少效率高,挺适合日常开发的。