我尝试将Kafka偏移量保存到文件中，我使用Spring boot，偏移量似乎在文件中写入，但没有读取，因此camel将在重新启动时从kafka主题的开头开始读取public classRoute extends RouteBuilder { public void configure() throws Exception {
kafka
浏览 0提问于2018-08-15得票数 0
我阅读了Camel Kafka的所有文档，我所读到的唯一方法就是这个和指定的路由生成器。public void configure() throws Exception {<!--DEFINE KAFKA'S TOPCIS AS ENDPOINT--
浏览 2提问于2018-07-20得票数 6
回答已采纳
我使用的是camel kafka组件，但我不清楚在提交偏移量时，幕后发生了什么。如下所示，我正在聚合记录，我认为对于我的用例，只有在将记录保存到SFTP之后才能提交偏移量。extends RouteBuilder {
public void configure() throws Exception {
from("kafka
浏览 49提问于2017-08-30得票数 2
回答已采纳
1回答
我正在尝试使用带骆驼的kafka，并设置以下路由： public class WorkflowEventConsumerRoute extends RouteBuilder { .to("mock:end);} 当我启动我的spring boot应用程序时，我可以看到路由开始了，但在这之后它立即关闭了，日志中没有给出任何原因： 2018: Kafka commitId : fa14705e51bd2ce5
201
浏览 9提问于2018-12-21得票数 1
回答已采纳
1回答
消息没有被消耗掉
、、、
我在Spring的application.properties文件中添加了以下配置和Camel实现，但是消息并没有被消耗。我错过任何配置了吗？有没有使用kafka协议和Camel从Azure事件中心实现消费者的指针？NAMESPACENAME.servicebus.windows.net:9093sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.commo
浏览 4提问于2021-10-11得票数 0
回答已采纳
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..。有点像. uri(kafk
浏览 2提问于2018-06-20得票数 0
我有一个Camel端点，它基本上是一个Kafka消费者，从主题中读取并将信息发送到数据库。它工作得很好，但是，我正在努力对它进行单元测试，因为我还不能模拟Kafka端点。@Override from(kafka:eph?
浏览 31提问于2020-04-03得票数 1
回答已采纳
我正在尝试为我的Spring Boot with camel routes应用程序编写单元测试。我的路由生产者是一个Kafka端点，URI是在application.properties文件中定义的。=localhost:9092我期望: Endpoint=mock://kafka<
浏览 10提问于2017-07-21得票数 0
回答已采纳
1回答
我在Spring应用程序中使用Camel。我需要的是在camel发送所有数据后正确关闭我的应用程序。基本上，camel必须读取一个文件，将其拆分成行，并将每行作为kafka消息发送。如何在camel完成发送所有消息后关闭我的应用程序？{
from("file:{{file.dir}}?:{{kafka.topic}}
浏览 0提问于2021-03-23得票数 1
2回答
我正在将Kafka配置为我的RouteBuilder中的源码。我的目标是处理Kafka断开连接的问题。我的RouteBuilder如下： public void configure() { // will do more processing here
浏览 2提问于2017-11-14得票数 2
当我启动camel上下文时，它运行5分钟(默认时间)。我可以让我的线程休眠一段特定的时间。永远运行，因为这个应用程序将被部署，它将侦听来自KAFKA服务器的消息。我知道有一门课但我不知道如何使用springCamelContext配置它，也不确定是否有其他方法。] INFO org.apache.camel.component.kafka.KafkaConsumer - St
浏览 16提问于2016-08-18得票数 2
(JaasConfig.java:111) ~[kafka-clients-3.1.1.jar:na] builder.setScheme("kafka"jaas属性外部化，但是我仍然得到了相同的错误，不确定在jaas配置中缺少了什么，或者它是camel kafka依赖的问题。>
<groupId>org.springframework.boot<
浏览 19提问于2022-06-04得票数 0
1回答
Camel JMS组件多线程
、、、、
我有一个spring boot应用程序，使用Camel的jmsComponent处理来自多个Solace队列的消息。我为每个队列连接定义了一个Camel route，并定义了一个将消息转换为json的Camel Processor。有大量来自队列的消息，而我的程序无法跟上速度。brokers={{spring.kafka.bootstrap-servers}}&securityProtoco
浏览 22提问于2020-07-21得票数 1
我一直试图找到Spring Boot Kafka Camel Avro消费者的示例代码，但没有运气。我在下面的url找到了Spring Camel Kafka消费者和生产者示例：
我的具体问题是，一旦我的bean从Avro Schema创建，并且我有了POJO类，我如何将上面的camel for
浏览 6提问于2016-08-04得票数 2
我们有一个接受kafka.KEY的路由，并将其用作mqtt url参数以将数据发送到正确的主题。<routes <route id="KafkaToMQTT"> <
浏览 19提问于2021-10-18得票数 0
回答已采纳
1回答
我有一个将Kafka流数据分发给MQTT主题的系统。阿帕奇骆驼路线看起来是这样的：<routes xmlns="http://camel.apache.org/schema/spring"> <fro
浏览 4提问于2022-05-11得票数 0
回答已采纳
在我的骆驼Router.java，我有下一个路线
from("jms:topic:test.source.topic?如果我向使用bin/kafka-console-producer.sh --topic testing --bootstrap-server localhost:9092运行的Kafka生产者向主题bin/kafka-console-producer.sh --topic testing --bootstrap-server localhost:9092发送一
浏览 1提问于2020-09-18得票数 1
回答已采纳
1回答
我有一个camel应用程序，它不能识别路由。这是一个spring boot应用程序。我已经定义了yaml文件中的所有属性。我的pom.xml有以下条目。 <jackson.version>1.9.13</jack
浏览 1提问于2020-12-19得票数 0
我正在尝试从camel 2.x迁移到3.x。我们的目标是创建一个包含Swagger文档的API。(ChildServiceSupport.java:60) ~[camel-support-3.4.3.jar:3.4.3]
浏览 29提问于2020-08-24得票数 3
我目前正在创建一个Springboot应用程序，它将使用Kafka主题的消息，处理后将写回另一个主题。我用骆驼来整合。.transacted()时，我得到以下错误: org.apache.camel.NoSuchBeanException: No可以在类型: PlatformTransactionManager的注册表中找到Spingboot项目中配置我的KafkaTransactionManager我已经注释了xml文件的某些部分
浏览 3提问于2021-05-17得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
