我有一个Kafka集群(版本: 0.10.1.0)，有9个代理和10个分区。 我尝试使用camel kafka 2.14.3从java应用程序中消费消息。这是我的pom.xml <dependency> <artifactId>camel-kafka</artifactId>
&
浏览 23提问于2020-06-16得票数 0
哪个camel kafka连接器组件可以从远程服务器读取文件并将记录发布到kafka主题？我尝试了camel-sftp-kafka-connector，但它将整个文件移到了主题。有没有连接器可以直接读取远程服务器上的文件？
浏览 27提问于2020-12-31得票数 0
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..。有点像. uri
浏览 2提问于2018-06-20得票数 0
1回答
我试着将Apache camel与Kafka集成，并编写了一个示例程序来读取文件并写入Kafka主题。但是当我这样做的时候，我得到的是错误。我可以做相反的方式从卡夫卡主题阅读和写入一个文件。斯塔克迹
org.apache.kafka.common.errors.SerializationException:无法将类org.apache.camel.component.file.Ge
浏览 2提问于2016-11-30得票数 0
回答已采纳
1回答
下面是我的配置(密码更改)camel.component.kafka.security-protocol=SSL
camel.component.kafka.ssl-truststore-location=C:/Users<
浏览 1提问于2021-06-24得票数 0
Spring boot Apache Camel-Java DSL应用程序从Kafka主题读取消息。Component from("kafkabrokers=localhost:9092")
.log("Message received from Ka
浏览 66提问于2020-11-29得票数 0
1回答
Camel JMS组件多线程
、、、、
我有一个spring boot应用程序，使用Camel的jmsComponent处理来自多个Solace队列的消息。我为每个队列连接定义了一个Camel route，并定义了一个将消息转换为json的Camel Processor。有大量来自队列的消息，而我的程序无法跟上速度。brokers={{spring.kafka.boo
浏览 22提问于2020-07-21得票数 1
我们有一个接受kafka.KEY的路由，并将其用作mqtt url参数以将数据发送到正确的主题。brokers=localhost:9092"/> <to uri="micrometer:
浏览 19提问于2021-10-18得票数 0
回答已采纳
我正在使用apache camel集成我的kafka消息。此外，我还使用JAVA DSL来使用来自kafka端点的消息。使用apache kafka API，它知道如何提交具有给定属性切换的消费者偏移量。
如果我在camel-kafka组件中取消了自动提交，那么我如何在apcahe camel中提交偏移量呢？我使用下面的端点在Apache Camel</e
浏览 9提问于2015-09-21得票数 5
2回答
我正在将Kafka配置为我的RouteBuilder中的源码。我的目标是处理Kafka断开连接的问题。我的RouteBuilder如下： public void configure() { // will do more processing here
浏览 2提问于2017-11-14得票数 2
我试图读取一个文件，并使用Camel kafka连接器将数据发送给kafka，但我需要将文件拆分为多条消息，并将它们分别发送给Kafka。是否可以使用camel卡夫卡连接器、camel文件- kafka连接器将数据分拆并单独发送给kafka？
提前谢谢。
浏览 10提问于2022-01-25得票数 1
我非常迫切地需要使用Citrus框架来支持Kafka集成测试。我正在考虑将现有的jms模块作为一个示例/框架，并使用Spring Kafka。有什么需要我注意的地方吗？
浏览 0提问于2018-03-13得票数 0
我有一个Kafka集群(版本: 0.10.1.0)，有9个代理和10个分区。 我尝试使用camel kafka 2.14.3从java应用程序中消费消息。这是我的骆驼路线 <route id="ReadFromTopic"> <log message=" BODY
浏览 35提问于2020-06-15得票数 1
2回答
我使用的是camel-kafka版本的2.14.3。下面是kafka URI： <from uri="kafka:{brokerlist}?但是，当我一次将多条消息发布到主题topic-name (全部发布到同一分区)时，kafka使用者会按顺序接收这些消息。如何并行接收这些消息？concurrentConsumers=2" /> 是我用来同时从ibm M
浏览 85提问于2020-04-21得票数 2
回答已采纳
我目前正在开发基于kafka的消息总线，由camel和Spring管理。:当kafka事件主题被轮询时，如果我的pollEnrich中的api.url不可用，则没有检索到业务对象，事件丢失。因此，我需要实现一个事务逻辑，以便能够回滚我的路由中的初始kafka轮询，以便同一事件可以被轮询多次，直到api.url将等待的业务对象发送给我。我尝试了几种方法，首先将我的o
浏览 1提问于2018-08-14得票数 4
作为我的客户端站点设计决策的一部分，http请求-响应流中涉及的组件(微服务)允许生成关于kafka主题()的消息，但不允许使用来自kafka主题的消息。这类组件(微服务)可以读写数据库，可以与其他组件对话，可以生成主题消息，却不能使用来自卡夫卡主题的消息。
相反，设计建议编
浏览 2提问于2021-01-29得票数 0
1回答
我在Spring应用程序中使用Camel。我需要的是在camel发送所有数据后正确关闭我的应用程序。基本上，camel必须读取一个文件，将其拆分成行，并将每行作为kafka消息发送。如何在camel完成发送所有消息后关闭我的应用程序？{
from("file:{{file.dir}}?:{{
浏览 0提问于2021-03-23得票数 1
我正在建立一个骆驼应用程序来阅读来自融合卡夫卡的信息。这些消息采用Avro格式，并添加到下面的路由配置中，以便使用Camel路由中的模式注册表读取Avro消息。当我启用valueDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer时，我不会收到任何来自卡夫卡主题的信息。我测试了没有模式注册中心的路由，并且
浏览 4提问于2022-02-02得票数 0
回答已采纳
1回答
我将为消息实现一个断路器模式。基本要求是，如果微服务无法将消息发布到发布主题，则应停止接受来自其他Kafka主题的消息。当发布主题可用时，微服务应该开始接受来自其他Kafka主题的消息。有没有办法在Spring boot Kafka Streams中实现这一点？
浏览 33提问于2020-11-30得票数 1
我正在使用在camel DSL中配置的kafka消费者来监听Kafka主题。还有另一个安装了kafka的应用程序(服务器)，它正在生成有关此主题的数据。<camel:endpoint id='docInfo' uri='kafka:${camel.kafka_broker}?topic=${camel.
浏览 4提问于2016-05-10得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
