Camel Kafka接收器连接器配置和依赖项

问题描述 投票:0回答:1

我正在尝试使用“camel-azure-storage-datalake-kafka-connector”从 Kafka 连接到 Azure ADLS Gen2

我有一个运行 Docker 的 Linux 机器,其中包含 debezium/zookeeper、debezium/kafka 和 debezium/connect 镜像。 使用 debezium 连接器从 cdc 表中获取更改是一种享受,因此我有包含消息的主题。

从这里我尝试使用 ADLS Gen2 的 Camel 接收器连接器将这些消息移动到 Azure 中。我对 Camel 很陌生,但是从连接器文档中可以看到,我可以将连接器作为包下载,将其解压缩到我的插件路径中,将一小段代码添加到 pom.xml 文件中,然后应该可以走了。但是,我没有 pom.xml 文件,到目前为止我还没有为此构建一个包,所以我的问题是:

  1. 如果我想使用任何驼峰连接器,是否需要 pom.xml?
  2. 如果是这样,针对我的特定用例执行此操作的最佳方法是什么?
java apache-kafka apache-camel apache-kafka-connect azure-data-lake
1个回答
0
投票

这个项目进行得怎么样?我很想看看你是否能成功完成这个任务。

© www.soinside.com 2019 - 2024. All rights reserved.