腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1369)
视频
沙龙
1
回答
Apache
Camel
作为
Kafka
的
生产者
/
消费者
、
、
在过去的两天里,我一直在研究
Apache
Camel
和
Kafka
,希望了解消息传递框架/代理。在使用
Camel
实现
生产者
和
消费者
的同时,
Camel
/
Kafka
是否有可能使用
Kafka
作为消息代理?如果不是,
Camel
:
Kafka
组件
的意义是什么?
浏览 8
提问于2018-01-17
得票数 1
回答已采纳
1
回答
Apache
Camel
-
Kafka
组件
-
单
生产者
多
消费者
、
、
、
、
我正在创建两个
apache
camel
(blueprint XML)
kafka
项目,一个是
kafka
-producer,它接受请求并将其存储在
kafka
服务器中,另一个是
kafka
-consumer,它从
kafka
服务器获取消息并处理它们。但是,如何在同一个
kafka
topic中创建独立的消费群?如何在不同
消费者
组内的同一主题内路由多个特定于
消费者
的消息?如有任何帮助,我们将不胜感激。谢谢你。
浏览 28
提问于2020-05-03
得票数 1
2
回答
使用Java为
apache
camel
中的自定义
组件
配置使用者
假设我有一个Jetty
组件
comp1和自定义
组件
comp2,其中comp1生成一个exchange,而comp2使用它。如何在comp2用户中实现Jetty
组件
的交换。到目前为止,我已经观察到,我们可以在
消费者
的轮询()方法as - SomeEndpoint终结点= camelContext.getEndpoint("someURI",SomeEndpoint.class
浏览 0
提问于2015-03-03
得票数 1
回答已采纳
4
回答
Apache
Kafka
+
Apache
Camel
集成+ java.util.Hashtable.put(Hashtable.java:459)上的POC issue+ java.lang.NullPointerException
、
、
、
、
我正在为阿帕奇
kafka
-
Camel
的POC工作。dependency> <groupId>org.
apache
.
camel
</groupId>错误是: at java.util.Hashtable.put(Hashtab
浏览 5
提问于2017-12-18
得票数 1
1
回答
ActiveMQ messageId无法停止重复数据
、
、
我正在使用ActiveMQ进行消息传递,有一个要求,如果消息是重复的,那么它应该由AMQ自动处理。为此,我生成了唯一的消息键并将其设置为messageproccessor。代码如下: jmsTemplate.convertAndSend(dataQueue, event, messagePostProccessor -> { long ms = dt.get(ChronoField.MILLI_OF_DAY) / 1000; String messageUniqueId = eve
浏览 36
提问于2020-04-08
得票数 0
回答已采纳
1
回答
如何使用
Camel
-
kafka
提交
消费者
偏移量?
、
我正在使用
apache
camel
集成我的
kafka
消息。此外,我还使用JAVA DSL来使用来自
kafka
端点的消息。使用
apache
kafka
API,它知道如何提交具有给定属性切换的
消费者
偏移量。 如果我在
camel
-
kafka
组件
中取消了自动提交,那么我如何在apcahe
camel
中提交偏移量呢?我使用下面的端点在
Apache
Camel
中禁用自动提交
浏览 9
提问于2015-09-21
得票数 5
3
回答
如何控制
Apache
Kafka
在特定时间内发出的消息数量?
、
、
、
我是
Apache
Kafka
的新手,我正在尝试配置
Apache
Kafka
,使其尽可能
多
地接收来自
生产者
的消息,但它只在每个特定时间向
消费者
发送配置数量的消息。
浏览 0
提问于2020-12-23
得票数 1
1
回答
Apache
camel
-如何检索给定
组件
的端点URI
我使用
Apache
Camel
2.20x。
camel
组件
可以用uri方案来开发,例如"sample- component“。现在这个
组件
的端点实际上可以扩展一个现有的端点,比如SQL,其uri语法为"sql:。现在,当我从"sql:事件中检索uri时,我正在侦听
camel
Exchange event (ExchangeSentEvent)。但我想要的是"sample-component“。简而言之,下面是一个问题:我们如何才能获得
cam
浏览 26
提问于2021-05-07
得票数 0
1
回答
强制
Camel
JMS/AMQP
组件
对
生产者
和
消费者
使用单独的会话
、
一些支持AMQP的代理,如Microsoft Service Bus或ActiveMQ,只允许每个会话有一个活动的
生产者
或
消费者
。
Apache
JMS
Camel
组件
似乎无法正确处理此问题,这导致JMS在处理从服务总线发送的InOut消息时抛出异常。有人知道如何克服这种行为吗?
浏览 1
提问于2014-02-21
得票数 0
1
回答
Spring boot
Kafka
Camel
Avro
消费者
、
、
、
我一直试图找到Spring Boot
Kafka
Camel
Avro
消费者
的示例代码,但没有运气。我在下面的url找到了Spring
Camel
Kafka
消费者
和
生产者
示例: 我的具体问题是,一旦我的bean从Avro Schema创建,并且我有了POJO类,我如何将上面的
camel
for spring示例告诉用户Avro序列化?具体来说,我指的是这行代码: f
浏览 6
提问于2016-08-04
得票数 2
1
回答
无法找到端点: test,请检查您的类路径包含所需的骆驼
组件
jar。
、
、
、
、
我试图使用akka-
camel
发送和接收消息,并为
生产者
和
消费者
创建了一个示例示例,如下所示:import akka.actor."HEY"
消费者
:import akka.
camel
.App { system.actorOf(Props[CamelJmsConsume
浏览 3
提问于2017-12-07
得票数 0
3
回答
如何使用
camel
-avro-consumer & producer?
、
、
、
、
我没有看到如何使用
camel
-avro
组件
来产生和使用
kafka
avro消息的示例?目前我的骆驼路线是这样的。为了使用
camel
-
kafka
-avro consumer & producer来使用模式注册表和其他类似的道具,应该对其进行哪些更改。pc.setLocation("classpath:application.properties"); log.info("About to start route:
Kafka
Serve
浏览 1
提问于2019-03-16
得票数 3
1
回答
基于
单
节点多代理配置的
kafka
用户
、
是否有人在
kafka
python上做过
单
节点多代理设置?我能够使用
单
节点
单
代理设置来生成和使用数据,但是当我将该数据更改为
单
节点时,会生成
多
代理数据并将其存储在主题中,但是当我运行时,
消费者
代码数据不会被消耗。from
kafka
.producer import KafkaPr
浏览 0
提问于2017-04-03
得票数 0
回答已采纳
4
回答
Delphi是否存在“多个
生产者
-单个
消费者
”的无锁队列?
、
、
我发现了几个
单
生产者
-
单
消费者
的实现,但没有一个实现是
多
生产者
-
单
消费者
的。 Delphi是否存在“多个
生产者
-单个
消费者
”的无锁队列?
浏览 0
提问于2009-07-05
得票数 13
回答已采纳
1
回答
使用
apache
camel
观察网络上的反应流
、
apache
camel
eip框架有一个支持reactive streams的
组件
。 从文档中我可以看出,reactive-streams
组件
只能在单个JVM中工作,来往于
camel
路由反应流。在一个应用程序中有一个
camel
生产者
,而在另一个应用程序中有一个
camel
消费者
,在网络上产生和消费反应流,应该有什么合适的机制? 我假设需要某种类型的中间件,哪种中间件适合这种情况?
浏览 19
提问于2019-10-15
得票数 3
回答已采纳
3
回答
Confluent
消费者
-主题[test-1]是/不存在的,missingTopicsFatal是真的
、
、
、
我在application.properties中提到了本地
Kafka
服务器配置(如注释掉的代码)application.properties#Remotebootstrap.servers=pkc-4kgmg.us-west-2.aws.confluent.cloud:9092sasl.jaas.config=org.
apache
.
kafka
.common.security.plain.PlainLoginModulereq
浏览 6
提问于2019-12-05
得票数 0
1
回答
盆景卡夫卡无法与阿帕奇骆驼连接
、
、
、
下面是我的配置(密码更改)
camel
.component.
kafka
.security-protocol=SSL
camel
.component.
kafka
.ssl-truststore-location=C:/Users
camel<
浏览 1
提问于2021-06-24
得票数 0
2
回答
使用
Camel
-
Kafka
的ProducerTemplate sendBody()方法创建端点生成器失败
、
、
我正在测试使用
Apache
在
Kafka
(0.8.2.1)上发送消息的简单
生产者
。我在
camel
中使用java创建了端点。:407) at org.
apache
.
camel
.impl.ProducerCache.sendExchangejava.lang.NullPointerExcep
浏览 1
提问于2015-07-07
得票数 4
回答已采纳
1
回答
Camel
ActiveMQ producer模板线程安全吗?
消息
生产者
使用请求/回复模式。在阅读
Camel
producer的文档时,需要注意的是,每个应用程序只能创建一个producer。
生产者
线程是否安全,以便我可以从多个线程调用send方法?
浏览 0
提问于2013-03-30
得票数 4
回答已采纳
1
回答
Apache
Camel
2.18.0
消费者
不消费
、
、
我们使用
apache
到2.17.*版本,以便利用我正在尝试升级到2.18.0的maxPollRecords参数。升级到2.18.0后,
消费者
似乎不再被经纪人所认可。下面是我试图创建的示例使用者。我可以生成从cli到主题的消息,如果我在cli中创建了一个
消费者
,我可以看到在cli中创建的
消费者
消耗了消息,而不是通过
apache
camel
创建的
消费者
。package com.test; import org.
apache
.
camel
.
浏览 3
提问于2020-08-14
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“集成架构”我们得谈谈 Apache Camel集成框架
“集成架构”我们得谈谈 Apache Camel
【行业资讯】Apache Camel 3.6.0 发布
大数据流处理:Flume、Kafka和NiFi对比
揭秘Kafka从入门到精通,架构最全详解
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券