第 36 章 Flink
从 Camel 2.18 开始
仅支持生成者
本文档页面涵盖了 Apache Camel 的 Flink 组件。camel-flink 组件在 Camel 组件和 Flink 任务之间提供了一个桥接。此组件提供了一种从各种传输路由消息的方法,动态选择要执行的 flink 任务,使用传入消息作为任务的输入数据,最后将结果传送回 Camel 管道。
36.1. 依赖项
当在 Camel Spring Boot 中使用 camel-flink
时,请将以下 Maven 依赖项添加到 pom.xml
中,以支持自动配置:
Maven 用户需要将以下依赖项添加到此组件的 pom.xml
中:
<dependency> <groupId>org.apache.camel.springboot</groupId> <artifactId>camel-flink-starter</artifactId> </dependency>