1回答
1、购买CKafka时的数量是指什么数量？
2、CKafka文档说兼容Kafka接口，是否所有可以访问原生Kafka的第三方工具都可以访问CKafka？3、CKafka是否支持Kafka streaming接口？
浏览 227提问于2017-11-22
例如，如果将readQueueNum设置为8，而将writeQueueNum设置为16，则不会处理一半的消息。
我试图在代码中找出这种设计的基本原理，但还没有找到任何线索。有人能帮我解释一下吗？
浏览 7提问于2019-05-12得票数 3
对于每个请求，记录将被发送到SQS队列，以便由另一个服务/组件进一步处理。消息结构如下所示：requestId: //request id common between all messages/records现在，我想知道何时从队列中读取了具有相同请求id的所有消息(即，对于该请求id没有更多的消息)。我的想法是在每次读取时将每个消息/记录写入数据库
浏览 0提问于2018-06-13得票数 0
我希望接收来自队列的消息，并立即将它们排出队列，实际上，我希望模拟rabbitMQ管理控制台的行为，该控制台可以接收消息并请求消息。
所以我的问题是怎么做？起初，我试图复制消息并重新发送消息，但似乎rabbitTemplate无法将消息直接发送到队列，而将消息发送到exchange并不是一种选择，因为多个队列可能会再次接收消息。然后，我开始想，我可以收到一条信息，
浏览 4提问于2014-09-16得票数 3
回答已采纳
1回答
似乎AWS控制台中的轮询总是长轮询，尽管队列被设置为短轮询。即使Receive message wait time设置为0时，它也总是轮询30秒。这有可能吗，还是我没明白？当我有一个DLQ连接到标准队列，并且队列的保留期结束时，消息是到达DLQ还是消失了？当尝试时，似乎消息消失了，但我想确定这是预期的行为。
浏览 9提问于2020-12-29得票数 0
回答已采纳
1回答
有一种解决方案建议支持这一点，方法是添加一个HTTP“代理”/endpoint，它使用correlationId将从这些客户端接收的消息推送到入站队列中，然后在出站队列中查找具有相同correlationId的消息。希望消息的处理已经完成，具有预期correlationId的消息将出现在出站队列中。这将发生在将消息推入核心系统以模拟请求响应的同一线程上。在当前的体系结构中，出站队列驻留在远程主机上，并对此进行了研究，以确定这
浏览 1提问于2011-02-03得票数 2
我正在尝试寻找一些关于如何使用jms模板和spring从队列中读取消息的教程。本质上，我想让用户告诉我队列中最后x条消息的数量谢谢
浏览 0提问于2014-11-12得票数 0
毕竟，在创建队列期间，我们使用以下过程绑定消息：PROCEDURE_NAME = proc_BrokerTargetActivProc。此外，我不确定我是否正确地理解了它的工作方式:使用要执行的过程名称的ExecuteProcedureAsync推到队列消息。现在怎么办？如何使用一条消息调用BrokerTargetActivProc？预先感谢，问候
浏览 0提问于2017-01-10得票数 0
回答已采纳
1回答
在我的项目中，我使用wso2 message作为消息代理系统。在使用wso2 message之前，我想探讨与wso2 message队列/主题相关的例外情况-
消息队列/主题
浏览 3提问于2016-07-03得票数 2
我有一个类似SNS、->、SQS、->、Lambda之类的设置。lambda函数将将一个文件保存到S3中，并将一个项保存在DynamoDB中。到目前为止我所拥有的是
请建议我，如果我们有一个更好的方法和解决方案，以解决“等待
浏览 0提问于2019-03-05得票数 0
2回答
在进程之间同步消息队列
、、、、
它们使用消息队列进行通信。其思想是生产者将“任务”发送到队列。工作者执行msgrcv()调用来获取任务并执行一些代码。当worker完成任务后，它将计算结果发送到队列。生产者将收到此消息并保存结果。我使用的是POSIX消息队列，生产者和工作者同时工作。
这个程序背后的问题是，存在一个损害通信的场景。每条消息的大小约为5000字节。在UNIX系统中，最大队列大小约为16000字节。场景是:队列中有3个任务(5000*3
浏览 4提问于2011-11-21得票数 3
回答已采纳
1回答
持续使用JMS消息
、、、、
我在Mule 4中有一个JMS侦听器配置，可以订阅Tibco JMS broker中某个主题的消息。如果出现任何故障，JMS消息将持久化到主题中。考虑在处理消息时是否存在运行时问题或一些间歇性问题，它将抛出异常，并且消息将持久保存在主题中。但这里的问题是，它将在没有任何延迟的情况下再次被使用，这将导致日志中连续的异常轰炸，以及由于相同的原因在DB错误日志表中存储的多个失败消息。
有没有办法在一定的延迟内消费来自主题的消息？
浏览 21提问于2019-11-22得票数 2
回答已采纳
假设我的消息被放到重试队列中(谁创建了重试队列？它是WCF还是MSMQ服务？)问:谁在超时后将消息从重试队列移动到应用程序队列？消息是否有“已移动”时间戳和“重试”时间戳？
浏览 5提问于2012-01-26得票数 4
回答已采纳
我看到消息队列比subprocess.Popen()更可取。据说消息队列是一种可伸缩的解决方案。我想知道是怎么回事。我只想在subeprocess.Popen()上列出消息队列的优点，这样我就可以说服上级使用消息队列而不是subprocess
浏览 4提问于2017-06-16得票数 1
回答已采纳
1回答
error log table
END CATCH
我的问题是:如果这个队列有多个队列读取器，那么在队列读取器A回滚事务后，另一个队列读取器B是否会接收到毒消息，并且由于所有消息都有自己的会话组，读取器A不能接收与会话句柄相同的消息？
浏览 5提问于2021-11-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
