flink-connector-kafka 3.4源码编译

一 .前言

本文为准备flink-connector-kafka 3.4 源码阅读环境.
记得关注一下 flink-connector-kafka里面pom.xml匹配的flink 版本.

官方入口文档

二 .安装文件准备

• 环境信息如下:

• 下载flink代码.
  从官方的github下载指定的代码

git clone git@github.com:apache/flink-connector-kafka.git flink-connector-kafka-1.20.0 -b v3.4

三 .编译

mvn clean package -DskipTests

[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary for Flink : Connectors : Kafka : Parent 3.4.0:
[INFO]
[INFO] Flink : Connectors : Kafka : Parent ................ SUCCESS [  3.429 s]
[INFO] Flink : Connectors : Kafka ......................... SUCCESS [ 15.211 s]
[INFO] Flink : Connectors : SQL : Kafka ................... SUCCESS [  2.471 s]
[INFO] Flink : Connectors : Kafka : E2E Tests ............. SUCCESS [  0.116 s]
[INFO] Flink : E2E Tests : Streaming Kafka base ........... SUCCESS [  0.835 s]
[INFO] Flink : E2E Tests : Streaming Kafka ................ SUCCESS [  6.319 s]
[INFO] Flink : E2E Tests : Common Kafka ................... SUCCESS [  1.515 s]
[INFO] Flink : Connectors : SQL : Kafka : Python .......... SUCCESS [  3.634 s]
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  33.714 s
[INFO] Finished at: 2025-01-02T10:51:47+08:00
[INFO] ------------------------------------------------------------------------

参考文档:
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/
https://github.com/apache/flink-connector-kafka