嗨，我正在努力寻找一个文档，在那里我可以轮询多个频道(比如2个pubsub主题或2个文件或2个jms主题等等)。然后将这些消息组合成一个.The，其意图是将来自不同通道的多个消息总结为一个消息。我知道camel中的聚合将允许我将多个消息组合到one.But中，当两个(或更多)消息</e
浏览 41提问于2020-06-14得票数 2
下面的代码从->源主题获取消息，并根据模板pubsub对其进行转换，然后将转换后的消息发布到目标主题。但是为了提高性能，我需要在parallel.That中完成这个任务，我需要轮询500条消息，然后并行转换它，然后将它们发布到目标主题。从camel gcp组件文档中，我相信maxMessagesPerPo
浏览 4提问于2020-04-29得票数 1
，对于任何不可预见的错误，我希望将问题消息放到gcp pubsub错误主题中。但是对于发布到pubsub错误主题中的任何错误(比如网络错误等)，我说的是“已处理”作为true.Hence，该错误将被默默忽略!！这对me.Now没有好处我丢失了消息，因为自从它被处理后，消息已经被自动确认，gcp pubsub将不会重新传递消息!！请让我知道我的选择
我刚看了一遍《骆驼行动》，Book.Below是正
浏览 4提问于2020-06-27得票数 1
背景:我们将云发布主题配置为在多个应用程序引擎服务中进行交互，在那里我们已经配置了基于推送的订阅者。我们已将其确认截止日期设置为600秒。问题:我们已经观察到pubsub已经将相同的消息两次(从其他主题上推了两次以上)给它的订阅者，从日志中我可以看到这个消息推送的间隔只有1秒，理想的情况下，由于我们已经将ackDeadline配置为600秒，所以
浏览 2提问于2018-11-29得票数 8
2回答
主持人开始一个“房间”，参与者可以加入并向该房间发送消息。然后是comet，但它还需要一个服务器端组件，我不
浏览 9提问于2012-01-09得票数 2
基本上，我想知道在Kafka和Pub/sub中是如何维护消息一致性、消息可用性和消息可靠性的
谢谢
浏览 0提问于2016-07-25得票数 101
1回答
consumerHandler)ssc.awaitTermination()
我的理解是，Spark和Kafka将自动协作，以确定要将多少个使用者线程部署到可用的工作节点上，这可能会导致对Kafka主题的消息进行并行处理但如果我不想要多个平行的消费者呢？如果希望1和只有1的消费者从主题中读取下一条消息，完全处理它，然后重新开始并轮询下一条消息，该怎么办？另
浏览 2提问于2016-08-15得票数 1
回答已采纳
1回答
我对Apache和ActiveMQ非常陌生，我发现要理解same.Infact的概念是非常困难和困惑的，我对整个same.Infact概念并不熟悉。我真的不明白Apache与ActiveMQ有何不同，因为根据我的理解，两者都具有将消息从一个系统路由到另一个系统的相同目的，反之亦然。
浏览 3提问于2015-03-05得票数 3
回答已采纳
Google Cloud Platform中的AWS Dead Letter Queue相当于什么？在Google Cloud平台中如何管理失败的记录？
浏览 1提问于2019-04-08得票数 5
在这个项目中，我们有两个数据流作业通过一个PubSub主题和订阅进行通信：
该管道基于每个消息工作，因此它没有自定义窗口策略应用，除了GlobalWindows在这条管道的末尾，我们击沉(写)了所有已经被分配给属性的映射的消息，包括它们的事件时间戳(例如"published_at")到使用PubsubIO.writeMessages()的PubSub主题</em
浏览 0提问于2018-10-08得票数 0
发送者将消息发送到队列的情况，例如，sender1将message1发送到队列。现在，一个名为consumer1的消费者连接到队列并读取消息message1。当下一条消息到达queue时，如果consumer2在consumer1之前读取队列，它可能会收到该消息。这是否意味着这一切都是一个情况，即一个消费者先读取队列，<
浏览 10提问于2017-12-23得票数 0
2回答
骆驼ActiveMQ性能调谐
、、、、
测试方法
我有两个应用程序，一个使用我们的旧实现，一个使用Camel实现。每个应用程序向本地ActiveMQ服务器上的主题发送JMS消息，并侦听该主题上的消息。这用于测试两种场景：-在一个循环中向主题发送100,000条消息，并查看从发送开始到结束处理所有这些信息所需的时间。-每100 ms发送一条消息，并测量从发送到处理每条消息的延迟(以ns为单位)。我已经<e
浏览 3提问于2013-01-18得票数 11
回答已采纳
我目前正在开发基于kafka的消息总线，由camel和Spring管理。<simple>${headers.MANUAL_COMMIT.commitSync()}</simple></route>
`我的问题是:当kafka事件主题被轮询时因此，我需要实现一个事务逻辑，以便能够回滚我的路由中的初始kafka轮询，以便同一事件可以被轮询多次，直到api.url将
浏览 1提问于2018-08-14得票数 4
1回答
该任务由多个工作进程(在我的例子中是AWS ECS实例)执行，它们从消息队列(在我的例子中是AWS SQS )读取数据。我有多个用户将消息添加到队列中。问题是，如果Bob向队列中添加了5000条消息，足以让工作人员忙碌3天，然后Alice出现并想要处理5个任务，Alice将需要等待3天，然后Alice的任何任务才能开始。我希望在Alice提交任务后，以相同的速率将消息从</
浏览 0提问于2019-06-20得票数 0
4回答
我正在使用Pubsub(推送)和Cloud Run，我将在其中部署一个使用Spring Boot构建的Java应用程序。 我有两个案子。我想： 推送消息(来自云函数)到全部(广播)的容器Service A 推送消息(来自云函数)到单一任意容器Service A 背景：我的Cloud Run服务将使用服务器发送的事件将数据直接推送到客户端这当然意味着容器/实例将保持一种状态。在某些情况下，我需要将消息推送到所有sse/ws连接 在所有容器上(想象一个带有公共聊天室的聊天
浏览 69提问于2021-02-14得票数 1
我有一个Camel路由，它从一个ActiveMQ JMS队列中读取，进行一些处理，并将结果传递到一个远程目的地。如果此进程的通信部分失败，我希望无限期地重试(直到目标“向上”)。我还有一个要求，就是我们应该能够从JMS中删除一个条目(我通过一个通过JMX与ActiveMQ对话的应用程序来实现)，并且处理应该转移到下一个消息。问题是，我既可以允许消息删除(通过将使用者设置为cacheLevelName=CACHE_NONE)，也可以允许连接句柄重试(通过将使用者设置为ca
浏览 2提问于2017-05-19得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
