如何将 Kafka 与 Camel Spring Boot 连接起来答案

【问题标题】：How to connect Kafka with Camel Spring Boot如何将 Kafka 与 Camel Spring Boot 连接起来
【发布时间】：2020-12-28 18:01:37
【问题描述】：

我有哪些选项可以将 Kafka 与 Spring Boot Camel 连接起来？

我正在运行 ActiveMQ Artemis 和 Camel，以创建往返客户端的 JMS/MQTT 和 REST 路由。我想将 Kafka 添加到该二人组中以流式传输/交换数据（视频+音频、文件/文本）。

到目前为止，我下载了 Kafka Confluent Platform（免费试用版），并且正在测试他们提供的功能。在 Confluent Platform 中，我看到可以将连接器添加为“插件”。我认为这样我可以添加 Camel 连接器，但这对我来说似乎是一个不好的解决方案，因为我想玩这些路线并看看引擎盖下有什么，而在这里我看不到这是可能的，还是我错了？

我正在考虑的其他选项是下载 Apache Kafka、Zookeeper，将 Kafka Spring Boot 依赖项添加到 Camel pom.xml，然后像示例 here 一样制作 Camel 路由。我在正确的轨道上吗？

【问题讨论】：

标签： spring-boot apache-kafka apache-camel

【解决方案1】：

卡夫卡经纪人

如果你想玩，我建议在你的开发机器上安装 Kafka（它还带来了 Zookeeper）。为您的操作系统使用 包管理器 是最简单的方法。例如，如果您在 Windows 上工作，则可以安装 Scoop。

然后你可以用单线安装当前版本的普通Kafka（非融合平台）：

scoop install kafka

安装后，您可以先启动 zookeeper，然后启动 kafka，使用 bin 文件夹中提供的 bat/sh 脚本。

骆驼

在您的 Camel 项目中（无论是否使用 Spring Boot），您只需将 camel-kafka 添加到您的依赖项中。

在您的本地机器上运行的 Kafka 代理的 路由端点 URI 是

kafka:[topic-name]?brokers=localhost:9092

您可以将此类 URI 用于消费者 (from("kafka:...")) 或生产者 (.to("kafka:..."))

【讨论】：

好的，我明白了。如果谈论 Linux，我认为 this 快速入门指南是非 Confluent 安装 Kafka 的良好起点。
现在我测试了 Confluent Platform (Docker) 并注意到它非常贪婪。将它与 Camel 连接起来很容易。我添加了 dependency 到 pom.xml 和简单的 Camel 路由来测试在 java 中从/到 Kafka 的发送。
Linux 快速入门看起来不错。非常棒，愉快的旅程！