如何解决如何将Kafka与Camel Spring Boot连接
我可以使用Kafka和Spring Boot Camel连接哪些选项？
我正在运行ActiveMQ Artemis和Camel，以建立往返于客户端的JMS / MQTT和REST路由。 我想将Kafka添加到该二人组中，以流式传输/交换数据（视频+音频，文件/文本）。
到目前为止，我已经下载了Kafka Confluent Platform（免费试用版），并且正在测试它们提供的功能。在Confluent Platform中，我看到可以将连接器添加为“插件”。我以为我可以添加Camel连接器，但是这对我来说似乎是一个不好的解决方案，因为我想尝试一下路线，看看幕后情况，在这里我看不到这种可能性，还是我错了？ >
我正在考虑的其他选项是下载Zookeeper的Apache Kafka，向Camel pom.xml添加Kafka Spring Boot依赖项，然后像在示例here中一样进行Camel路由。我在正确的轨道上吗？
解决方法
卡夫卡经纪人
如果您想玩转，我建议在您的开发计算机上安装Kafka （它也带来了Zookeeper）。在您的操作系统上使用程序包管理器是最容易的。例如，如果您使用Windows，则可以安装Scoop。
然后，您可以使用单线安装当前版本的纯Kafka（非融合平台）：
scoop install kafka
安装后，您可以
骆驼
在您的Camel项目中（无论是否使用Spring Boot），您只需要将camel-kafka添加到您的依赖项中。
在本地计算机上运行的Kafka代理的路由端点URI 是
kafka:[topic-name]?brokers=localhost:9092
您可以将此类URI用于使用者（from("kafka:...")）或生产者（.to("kafka:...")）
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。