Apache Flink Google Cloud PubSub 连接器使用教程

42 0 0

Apache Flink Google Cloud PubSub 连接器使用教程

flink-connector-gcp-pubsubApache Flink 是一个开源的流处理框架。该项目是一个 Google Cloud Pub/Sub 连接器，用于将 Flink 与 Google Cloud Pub/Sub 集成。适合熟悉 Java 和流处理开发的开发者。特点包括流处理、Google Cloud Pub/Sub 集成和开源项目。项目地址:https://gitcode.com/gh_mirrors/fli/flink-connector-gcp-pubsub

1. 项目的目录结构及介绍




flink-connector-gcp-pubsub/


├── docs/


│   └── README.md


├── flink-connector-gcp-pubsub-e2e-tests/


│   ├── src/


│   └── pom.xml


├── flink-connector-gcp-pubsub/


│   ├── src/


│   │   ├── main/


│   │   └── test/


│   └── pom.xml


├── flink-examples-streaming-gcp-pubsub/


│   ├── src/


│   └── pom.xml


├── tools/


│   └── asf.yaml


├── .gitignore


├── .gitmodules


├── LICENSE


├── NOTICE


├── README.md


└── pom.xml

docs/: 包含项目的文档文件，如 README.md。flink-connector-gcp-pubsub-e2e-tests/: 包含端到端测试的源代码和配置文件。flink-connector-gcp-pubsub/: 核心模块，包含连接器的源代码和测试代码。flink-examples-streaming-gcp-pubsub/: 包含使用连接器的示例代码。tools/: 包含项目使用的工具配置文件。.gitignore: Git 忽略文件配置。.gitmodules: Git 子模块配置。LICENSE: 项目许可证文件。NOTICE: 项目通知文件。README.md: 项目介绍和使用说明。pom.xml: Maven 项目配置文件。