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