如何将Kafka与骆驼Spring靴连接
我有哪些选项可以将Kafka与Spring靴骆驼连接？
我正在运行ActiveMQ Artemis和Camel，以建立进出客户端的JMS/MQTT和REST路由。我想把Kafka添加到这个二重唱中，以流式传输/交换数据（视频音频、文件/文本）。
到目前为止，我下载了Kafka汇合平台(免费试用)，我正在测试他们提供什么。在融合平台中，我看到有可能将连接器作为“插件”添加。我假设我可以添加Camel连接器，但这对我来说似乎是个坏的解决方案，因为我想玩玩路线，看看引擎盖下是什么，在这里我看不到这是可能的，或者我错了吗？
我正在考虑的另一个选择是下载阿帕奇Kafka，动物园管理员，将KafkaSpring靴依赖性添加到骆驼pom.xml然后制作骆驼路线，就像在这里的样本中一样。我是否走在正确的轨道上？
共有1个答案
Kafka-经纪人
如果您想尝试一下，我建议在您的开发机器上安装Kafka（它还带有Zookeeper）。为您的操作系统使用包管理器是最简单的。例如，如果您在Windows上工作，可以安装Scoop。
然后，您可以使用单行安装当前版本的普通Kafka（不是融合平台）：
scoop install kafka
安装后，您可以先启动zookeeper，然后在bin文件夹中使用提供的bat/sh脚本启动kafka。
骆驼
在您的Camel项目中（无论Spring Boot与否），您只需要将camel-kafka添加到您的依赖项中。
在本地计算机上运行的 Kafka 代理的路由终结点 URI 为
kafka:[topic-name]?brokers=localhost:9092
您可以将此类URI用于消费者（from（“kafka:…”））或生产者（.to（“kaf ka:…“））
-
我有一个Spring Boot2.25.1应用程序，它使用Camel 2.25.1与camel-kafka，一切都正常工作…在我的Kafka消费者中，我需要添加该功能以按需暂停消费，因此我升级到camel 3.18.1，以便我可以使用可暂停功能。升级到3.18.1后，我收到错误FileNotes与类文件TimeoutAwareAggregationStategy.class. 当我打开camel-
-
我一直在尝试为Spring引导Kafka骆驼Avro消费者寻找示例代码，但没有运气。我在以下URL找到了Spring Camel Kafka消费者和生产者示例： https://thysmichels.com/2015/09/04/apache-camel-kafka-spring-integration/ 我的具体问题是，一旦我的bean从Avro模式创建，并且我有了POJO类，我如何将上面的c
-
没有“org.apache.camel.CamelContext”类型的合格bean可用：应至少有一个合格的自带候选bean。 依赖项注释：{@org.SpringFramework.Beans.Factory.Annotation.AutoWired(required=true)}
-
背景：我按照这个链接设置了AWS MSK，并测试了生产者和消费者，它的设置和工作正常。我能够通过两个单独的EC2实例发送和接收消息，这两个实例都使用同一个Kafka集群（我的MSK集群）。现在，我想建立一条从Eventhubs到AWS Firehose的数据管道，其形式如下： Azure Eventhub- 我能够成功地做到这一点，没有使用MSK（通过常规的老Kafka），但由于未说明的原因，需要
-
我已经尝试了几个小时来获取Spring Boot应用程序的Camel路由（通过Camel组件camel-google-pubsub连接到Google Pubsub模拟器的本地实例），但没有成功。 null null 如果有人已经成功地使用pubsub模拟器与他们的骆驼路线，我对您的解决方案感兴趣。
-
我最近注意到Camel现在有自己的Kafka组件，所以我决定给它一个旋转。 我决定尝试一个很好的简单文件->kafka主题如下...