1回答
我必须测试消息传递服务，并想知道是否有任何经过验证的技术专门用于测试消息传递服务。例如，我知道JMeter对JMS的支持。这将涵盖负载/性能测试。然而，我不是在寻找工具，而是寻找概念和技术。
浏览 0提问于2016-04-25得票数 2
我发现Bigtable集群由一个主服务器和多个tablet服务器组成。失败时master发送到tablet服务器的消息。将平板电脑的备份副本设为主要副本。GFS自动创建的tablet的额外副本。
这足够了吗？但我想知道如何解决它，或者程序是什么，或者实际上是遵循了哪些步骤来解决它？
浏览 0提问于2015-11-04得票数 2
我想学习更多关于编程消息传递应用程序和使用消息队列的知识。像qpid，亚马逊队列等的事情。你能告诉我一些应用程序(最好是C++，如果可能的话，开源)，这样我可以了解更多。
另外，您能告诉我决定是否不使用消息队列的一般指导原则吗？我对leanring很感兴趣，只是因为“酷”的因素，但我认为这对我未来可能是有益的。
浏览 0提问于2011-02-12得票数 2
回答已采纳
1回答
我有成百上千个节点，每个节点都知道彼此的地址。 为了有效地在它们之间传播信息，我目前认为我需要将它们转换为一棵树，或者可能是多棵树。 我读过https://en.wikipedia.org/wiki/Broadcast_(parallel_pattern)，但它似乎不能处理消息丢失。 如果消息有1%的失败机会，是否有办法将消息传送到99%的节点？速度在这里很重要，所以不需要重试和/或TCP。 当消息失败时，一个简单的树广播将丢失整个分支。也许多棵树就能解决这个问题？多少? 我很高兴节点能够接收少量冗余消息。我需要使用UDP。少量的绝对故障是可以的，因为它们可以在稍后的时间赶上自己，在此期间退
浏览 19提问于2020-09-12得票数 0
1回答
这个错误意味着什么？
我使用Java部署了5个Lambda函数，这些函数工作得很好，但从今天下午开始，它们都开始在执行每个函数时显示相同的消息：
Service error.
没有输出，没有日志，只有红色框中的消息。
在中，他们说：
下午6:05下午PDT我们正在调查增加的错误率和提高的AWS Lambda请求在美国-东部-1地区。新创建的函数和控制台编辑也会受到影响。
为什么会发生这种情况，是否有办法防止这种情况发生？
浏览 2提问于2016-08-11得票数 1
回答已采纳
我正在使用MT和RabbitMQ实现标准的请求/响应场景。客户端是Asp.net核心应用程序接口，消费者是windows服务。
作为测试异常用例的一部分，如果我停止使用者并使用请求客户端提交来自API的请求，由于没有使用者处理，API得到请求超时异常，这很酷。但是消息位于消费者队列中，当我启动消费者时，它会挑选消息并处理这些东西(将消息发送到外部端点)，然后移到_skipped队列中，因为没有请求客户端监听此消息。
你认为这是正确的行为吗？首先当api得到请求超时异常时，他还是会重试，那么处理第一条消息还有什么意义呢？
如何忽略那些请求客户端已经完成处理但出现错误的消息？
谢谢
浏览 26提问于2021-03-05得票数 0
1回答
我有一个应用程序，它由运行在一个或多个系统上的一组Java和C++组成，并且需要能够监视和控制组件，就像它们是一个完整的系统一样。
我的要求：
运行时统计(每秒消息等)
事件日志
控制：“服务X设定为1000 mps”或“所有服务停止”。
环境配置，以便所有服务都可以启动并发现工作模式(等等)
由于数据平面消息传递是基于0MQ的，所以我目前正在使用基于0MQ的消息传递和消息分发器来扇出控制消息。
不过，我对其他人如何处理这个问题很感兴趣。
谢谢。
浏览 0提问于2013-05-06得票数 1
OpenStack使用消息传递(我想是默认的RabbitMQ ?)用于节点之间的通信。另一方面，Kubernetes (继承了Google内部的Borg)使用RPC。Docker的swarm也使用RPC。两者都是基于gRPC/protofbuf的，这似乎在Google内部也被大量使用。
我知道像Kafka这样的消息平台被广泛用于流数据和日志聚合。但是像OpenStack，Kubernetes，Docker Swarm等系统需要在节点之间进行特定的交互，而远程过程调用似乎是一个自然而然的选择，因为它允许为特定的操作定义API。
OpenStack是在评估消息传递与远程过程调用的优缺点后选择消息传
浏览 72提问于2017-12-02得票数 23
Kafka Consumer (org.apache.kafka:kafka-clients:2.3.0)应该使用一个分区消费来自topic的消息。 该服务记录消费者订阅，但它不使用消息，也不会使用Official Apache Tools kafka-consumer-groups.sh出现在消费者组列表中。 2020-06-15 11:50:50.308 [main] INFO o.a.k.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=my-groupid] Subscribed to t
浏览 129提问于2020-06-15得票数 0
回答已采纳
我已经在CAN中创建了一个CAN模拟系统。我已经添加了两个capl文件，其中包含一个ID为1的CAN消息处理程序。现在，如果我收到ID为1的CAN消息，这些处理程序将按什么顺序被调用？
谢谢
浏览 1提问于2015-06-11得票数 1
2回答
我正在将基于酸的monolith迁移到基于事件的微服务体系结构。在monolith中，潜在的大型文件存储在数据库中，我希望与微服务共享这些信息(包括文件内容)。
我的方法是将文件分割成有编号的块，并发送几条消息(例如，带有元数据和id的一个FileCreatedMessage，后面是包含该块及其序列号的n FileContentMessage )。在接收端，消息可能不会按顺序到达。因此，我会存储消息块，订购并加入它们，并存储结果。
有什么方法可以让我用一条消息或另一条信息通过Kafka传输数据，而不需要为几条消息实现分片、排序和连接逻辑的开销？
我注意到卡夫卡溪流。它似乎解决了与这个不同的问题
浏览 0提问于2019-06-09得票数 5
回答已采纳
我有一个实时聊天的应用程序。聊天是在客户端和服务器端(nodejs)使用Faye实现的。
现在，这个客户端聊天被用于rails应用程序，当我的页面重新加载/刷新时，我不想丢失在以下场景中可能发生的消息：
我重新加载页面
我从DB那里得到聊天记录
用户在聊天的另一边写5行
我呈现这一页
我丢失了5份最近的记录
我想听听你对解决这个问题的意见。我想到了一个类似于消息队列的消息队列，其中没有传递给客户端的消息将在那里等待，然后在页面通过javascript打开时被获取。
如果有人确认消息队列非常适合使用zeromq或在redis中实现简单队列，我还需要您的意见，因为我已经
浏览 2提问于2012-10-02得票数 1
回答已采纳
最近，我尝试了Netty服务器来开发一个聊天服务器。我已经重复使用了示例"io.netty.http.example.websocketx.server"，并通过添加通道映射、消息处理器将新消息保存到数据库等方式稍微修改了它。
通道映射将包含所有已打开的频道和订阅的聊天室id。因此，当有人向聊天室123发送消息时，当收到messageReceived函数中的消息时，服务器将将消息发送到订阅到该聊天室的所有通道。
当只有一个WebSocketServer实例时，这个方法工作得很好，但是，如何将负载平衡到多个WebSocketServers呢？当WebSocketServer #1
浏览 5提问于2014-07-09得票数 1
回答已采纳
websphere MQ附带了什么样的数据库？DB2分号？或者基于db的本地文件系统。它需要某种形式的持久存储，因为如果它在队列上接收到消息，而侦听器处于下线状态，那么它需要持久化消息，直到侦听器备份。
浏览 2提问于2013-10-10得票数 1
回答已采纳
3回答
在对的一个回答中，用户提到了消息传递应用编程接口。我还遇到过一个名为的程序。我对也有一定的了解。
所以，我的主要问题是:为什么我要选择一个而不是另一个？更具体地说，当有成熟的MPI实现时，我为什么要选择使用when或ÖMQ呢？
浏览 0提问于2008-08-30得票数 47
回答已采纳
1回答
系统从MQ获取消息。由于系统具有多个VM，因此处理消息的实际顺序可能与MQ中的顺序不同(等等。可以在前一条消息之前处理后一条消息，并将其存储在数据库中)。
现在我希望具有相同Business-ID的消息可以在发送时作为订单进行处理。
我可以得到一个建议，我们可以使用一个VM并从MQ读取消息。并获取Business-Id并将消息分发到目标VM (具有相同Business-Id的消息将分发到相同的VM)。它可以解决这个问题，但是只有一个线程来做分发工作，性能可能不好。
有没有其他方法来解决这个问题？任何博客、论文、开源代码都可以。
浏览 0提问于2019-06-13得票数 0
我在比较Apache Kafka和ActiveMQ (以及类似的消息队列产品)时发现的信息从来都不清楚每个解决方案的完整性属性(特别是一致性)。
使用Kafka，您可以获得即使在出现故障时也不会丢失消息的保证。使用"LazyPersistence“选项会失去这种保证吗？
所谓“无损失”，我的意思是消息将对客户端可用，即使在重启后出现故障-理想情况下，所有到达客户端的消息都以正确的顺序。
ActiveMQ ( "classic“或Artemis)是否保证失败时不会丢失消息？有没有什么配置选项可以保证这一点？如果"classic“和Artemis的答案不同，那就太好了。
浏览 3提问于2020-08-23得票数 0
我对消息代理(例如RabbitMQ )和面向消息的中间件之间的区别感到有点困惑。除了维基百科上的内容，我找不到太多的信息。在搜索MOM时，我找到了AMQP上的信息，其中说明了MOM的协议。这是什么意思？那妈妈是什么呢？我还了解到RabbitMQ实现了AMPQ协议。那么为什么这会使RabbitMQ成为消息代理呢？消息代理和MOM是一回事吗？
希望一些人能解开我的困惑。谢谢
浏览 18提问于2012-11-03得票数 29
在接收单个队列使用者和多个生产者时，是否可能出现消息顺序问题？producer1在2021-06-27 02:57:44.513上发布消息m1，在同一队列worker_consumer_queue上在2021-06-27 02:57:44.514上发布消息m2。连接到配置为单个使用者的队列的客户端代码应该首先按照m1的顺序接收消息，然后按照m2的顺序接收消息，对吗？有时接收消息的顺序不对。版本为ActiveMQ Artemis 2.17.0。尽管我提到了多个生产者，但使用属性blockOnDurableSend=false从同一个线程逐个发布消息。
我创建并关闭每个消息发布的生产者。在同一个J
浏览 3提问于2021-06-27得票数 0
回答已采纳
我对以下内容的基本理解：
分布式计算是一种连接节点的模型，从-from硬件的角度来看，它们只共享网络连接-并通过消息进行通信。每个节点代码负责一部分业务逻辑，因为在ERP系统中有一个节点负责hr，一个节点负责记账。通信可以是HTML、SOA、RCP
微服务是一种服务，它负责业务逻辑的一部分，并通常通过http进行相互通信。微服务可以共享硬件资源，并通过它们的api访问。
并行系统是优化资源使用的系统。例如，多线程应用程序运行在共享内存资源的多个线程上。
我有点困惑，因为微服务是分布式系统，但当在单个硬件资源上运行多个微服务时，它们也是并行系统。我是不是已经明白了：
浏览 0提问于2016-12-10得票数 18
1回答
我需要创建一个具有计时器/定期检查两个时间戳的分布式应用程序。是否有可能通过行为者模式实现以下行为：
产卵儿童演员
向子参与者发送消息，启动检查时间戳的例程
在计时器过期时不接收任何可用作触发器的消息时执行一些操作
传入的消息可以更改将定期检查的时间戳。
如果失败，主管需要用最后两个收到的时间戳恢复失败的参与者。在执行由计时器触发的事件时稍微延迟(重新启动参与者和重新应用状态)是可以接受的。
任务的关键目标是不丢失任何应该发生在两个时间戳之间一定时间内的事件，并不惜一切代价消除单个故障点。
演员模型(用Erlang或AKKA实现)是否适合解决这个问题？如果不是，其他更适合这种情况的模型/系统是
浏览 0提问于2018-09-23得票数 5
我编写了以下代码，以便将一些消息写入SQS队列并立即删除它们。但是，我在输出中看到，每条消息都会被即时删除。然而，我看到消息计数非常随机地出现。我的意思是，它最初显示1，然后再次显示2，尽管又删除了一个。我已经将可见性超时设置为50秒，就像在这个中提到的那样。作为程序的一部分，我尝试了相同的方法。
所以我的疑问是删除消息是否会立即发生。如果是这样，这将如何影响线程计数。请看下面的代码和输出。
__author__ = 'Dhanapathi.Marepalli'
import boto.sqs
conn = boto.sqs.connect_to_region("u
浏览 0提问于2015-11-02得票数 0
1回答
对于那些熟悉的人来说。这些模式是DDD的良好补充吗？最初，我认为它们更适合分布式企业应用程序，但我注意到，一些仅将数据库作为外部服务的复杂项目确实受益于消息传递模式。
我一直回避这本书，因为我对高度分布式的服务器端软件不感兴趣。然而，考虑到我越来越多地使用领域事件和事件采购，我有一种感觉，那本书中的模式很可能会在任何DDD项目中重用。
EIP是DDD从业者的必读之书吗？
浏览 2提问于2013-06-25得票数 3
回答已采纳
我花了很长时间来考虑去中心化应用程序及其优势，特别是当涉及到大量流量时，它们往往更可靠、更便宜的事实，而集中式应用程序则不是这样(最好的例子是facebook或google，这些服务器消耗大量能源)。
我的问题是：
Kademlia可以用于聊天协议吗?它的安全性如何？如果我启用了数据包加密，是否可以保证隐私？如果我调整协议，其他类型的消息传递应用程序是否可以与kademlia (论坛/usenet、电子邮件、IRC)一起使用？
我确信我需要添加很多代码来保护隐私，这样任何人都可以窃听或利用Sybil攻击(在维基百科上有描述)。
你觉得呢？你认为这个项目值得吗？
(为我糟糕的英语道歉)
浏览 2提问于2011-06-17得票数 3
回答已采纳
1回答
动物园管理员是一个协调服务机构，负责处理以下问题-
如果集群中的一个节点发生故障，动物园管理员将查找另一个节点。
处理对共享资源的序列化访问
种族状况死锁。
其他流行的消息传递系统没有动物园管理员。他们当然应该面对动物园管理员声称要解决的问题。
Q1)他们有其他方法来解决这些问题吗？对那些方式放点光。
Q2)他们找到了一种与这些问题共存的方法吗？
浏览 0提问于2019-07-28得票数 0
3回答
在编写分布式算法代码时，是否使用任何库来对处理器、寄存器、消息、链接等抽象事物进行建模？有没有能做到这一点的库？
例如，我在考虑自稳定算法，比如自稳定的最小生成树算法。
浏览 10提问于2009-05-29得票数 3
回答已采纳
在spring boot应用程序中，我们在数据库上有一个分页循环，它将使用JMSTemplate为每个页面发送一条JMS消息。包含循环的方法是@Transactional。创建JMSTemplate时，transacted标志设置为真。 我一直在浏览JMSTemplate的源代码，据我所知，如果已经有外部事务正在进行，它将不会提交事务会话，而是会将其放入该事务中。 现在让我们考虑以下代码： @Transactional
public void loopThroughPages(String destination, String from, String to) {
Pageable
浏览 26提问于2018-12-20得票数 3
回答已采纳
1回答
在Saga模式https://microservices.io/patterns/data/saga.html和下面的用例之间有一个细微的区别。Saga模式是关于事件发生时的分布式事务，下面的用例是事件发生后的协调模式。
我们有一个巨大的微服务生态系统(300+)在一个部门(2000+雇员)。我们的所有服务都松散地遵循消息驱动的体系结构。例如，在电子商务世界中，我们有一个系统A，它发送消息Customer X placed an order for item Y for $4.50. Order Id is 123。然后有一个系统B，它可能是一种支付服务，它接收此消息，并以4.50美元实际借记
浏览 0提问于2021-06-15得票数 -1
请原谅我的基本问题，但我在谷歌搜索中没有找到我的答案。
我想开发一个服务器，应该响应数百个客户端。每个客户端每秒可以发送数十到数百条消息。
我想知道如果我使用AMQP (RabbitMQ实现)或ZeroMQ之类的排队协议，服务器应该支持多少个TCP连接？
是客户端总数还是每秒消息总数？
浏览 0提问于2015-06-20得票数 0
2回答
我在NSObject.h中发现了一个奇怪的关键字
- (oneway void)release;
我在网上搜索，了解到它与异步消息传递有关，它看起来与Erlang的消息传递相似。
看起来这可以做很多有趣的事情。这个关键字有哪些好的用例？
浏览 7提问于2011-03-31得票数 108
回答已采纳
2回答
我正在阅读Lamport关于拜占庭将军问题的论文，我想问以下问题:为了让算法工作，我总是需要知道出错进程的数量吗？例如，如果我有一个无法知道有多少进程可能生成错误消息的网络，我不能使用Lamport的解决方案(口头消息或签名消息)吗？
谢谢!！
浏览 1提问于2015-11-12得票数 0
1回答
我一直在阅读关于共享内存和消息传递的文章，我相信共享内存比消息传递更快，但是我似乎没有遇到消息传递的优点。与共享内存相比，消息传递有什么优势吗？
浏览 3提问于2014-10-15得票数 2
回答已采纳
大家好，
我正在评估一个多数据中心分布式系统的一些组件。我们将使用消息队列(通过RabbitMQ或Qpid)，这样代理就可以向其他代理发出异步请求，而不必担心寻址、路由、负载平衡或重传。
在许多情况下，代理将与设计为高度并发访问的组件交互，因此需要锁定和跨代理协作以避免竞争条件。此外，我们希望系统能够自动响应代理或数据中心的故障。
考虑到上面的用例，似乎是一个很好的选择。但我想知道，尝试同时使用ZK和消息队列是否过火了。这似乎是由我自己的集群管理器使用AMQP消息来完成的，但这是很难做到的。另一方面，我看到了一些使用ZooKeeper实现消息队列的例子，但我认为RabbitMQ/Qpid更适合
浏览 6提问于2010-04-19得票数 15
回答已采纳
4回答
我分别找到了分布式系统和分布式计算的以下定义：
分布式系统：与互连网络相连的独立计算机的集合。
分布式计算：计算机处理的一种方法，其中一个计算机程序的不同部分在两个或多个通过网络相互通信的计算机上运行。
然而，我不清楚这两者之间的区别是什么。分布式系统和分布式计算有什么区别？
浏览 9提问于2017-09-28得票数 10
1回答
让我们假设我想使用AKKA参与者模型来创建一个程序，处理来自文件的数据。据我所知，由于该模型正在获胜，如果参与者真的不知道他们在哪里运行，那么传递消息中的文件路径应该是错误的-some参与者，而应用程序可能无法访问该路径-。相反，由于资源问题，将整个文件作为字节传递将不是一个选项(如果文件越来越大怎么办？)处理这种情况的正确策略是什么？在同一个问题上:假设有一个分布式文件系统会成为接受路径作为消息的好借口吗？
浏览 4提问于2022-02-21得票数 1
回答已采纳
1回答
我试图通过使用KafkaConsumer.assign(分区)、KafkaConsumer.seek(分区，偏移)来实现从Kafka随机访问消息的方法。然后阅读一条消息的民意测验。
但在这种情况下，每秒不能超过500条信息。相比之下，如果我“订阅”分区，我将获得100,000+ msg/秒。(@1000字节msg大小)
我试过：
经纪人，动物园管理员，消费者在同一主机和不同主机上。(不使用复制)
1和15个分区
默认线程配置在"server.properties“中，并增加到20 (io和网络)
每次分配给不同分区的单个使用者，每个分区分配一个使用者。
使用单个线程
浏览 0提问于2019-04-12得票数 1
回答已采纳
我一直在尝试打印带有多个分区的消息。我知道消息是在单个分区中排序的，但是我如何实现这一点，以便消息也可以通过多个分区进行排序？
例如，我发送1,2,3,4, 5，它们被发送到不同的分区，但是由于它们是按1到5的顺序发送的，所以我也希望它们按照这个顺序打印，但是它们被打印为2,3,5,4,1。我也有他们的时间戳，但也不能按照这个顺序来实现。
浏览 5提问于2022-08-26得票数 0
2回答
我需要写一个排队系统，我想知道在MSMQ的Microsoft服务器周围有什么替代方案来排队消息？
我对MS-DTC和BizTalk略知一二，但这些选项的优缺点是什么，我是否遗漏了什么？
我需要按顺序传递消息，并且有可能需要水平扩展的能力。
我每小时要处理大约100,000条消息，每条消息不到256kb。
谢谢
浏览 1提问于2011-06-07得票数 2
回答已采纳
作为一名初级数据工程师，我希望能确切地理解为什么我们需要卡夫卡。我假设Kafka是一个消息队列程序，充当数据生成和消费系统之间的中介。那么，为什么我们不能仅仅使用一个正常的数据库或数据湖作为中央存储，让它充当系统之间的代理呢？
浏览 13提问于2022-08-01得票数 0
1回答
我有需要相互发送和接收消息的对象A和B。
例如：
我点击，这会导致A发送一条消息给B。B对它做了一些事情，然后发送A另一条消息作为回复。
现在我的方法是，A有一个B*，B有一个A*，它们调用彼此的sendMessageTo方法进行通信。
有没有更好的方法来做这类事情？
基本上，服务器发送一条消息，或者本地游戏发送一条消息，由多态中介器接收。中介者从服务器或本地游戏获取消息。中介器将其传递给客户端，客户端对其执行任何操作。这个想法是中介者不应该为客户端做逻辑，因此消息传递。
浏览 0提问于2011-10-16得票数 0
回答已采纳
1回答
我们正在实施一个从卡夫卡中读取并写入BigQuery的试点项目。
简单管道：
KafkaIO.readBigQueryIO.write
我们关掉了自动投递。我们使用的是commitOffsetsInFinalize()
这种设置能否保证消息至少在BigQuery中出现一次，并且不会丢失，前提是BigQueryIO端一切正常？
在commitOffsetsInFinalize()的文档中，我遇到了以下几个方面：
帮助最小化空白或重复处理记录，同时从零开始重新启动管道。
我很好奇，这里提到的“空白”是什么？
如果您考虑到边缘的情况，是否有一种可能的消息被跳过，而没有交付到烧烤？
浏览 5提问于2021-01-29得票数 0
我有一个使用案例，我们使用Kafka中的数据。Kafka中的消息将与一个key关联，以维护每个分区中的顺序。现在，当我使用这些消息时，我必须并行处理这些消息，而且我不应该错过按键分组的消息序列。
为了实现并行性，我们可以使用线程，但不能保证排序。在我们的用例中，排序永远不会受到影响。感谢在实现并行性+排序方面的任何帮助。
浏览 1提问于2021-04-23得票数 0
2回答
我有一台16核心的64 G服务器。我将node.js用于基于微服务的体系结构。大约有十几个微型服务。似乎很适合在同一台机器上部署所有的微型服务。
通常，人们在REST和消息传递之间进行辩论，而消息传递通常是赢家。在这种情况下，两者都会出现不必要的开销。
微服务应该如何沟通。例如，使用节点js或基于JVM的进程。理想情况下，如果每个微服务被“绑定”到一个核心，并使用L2或L3缓存与其他人通信，那么最好的性能就会出现！超快。有可能这样做吗？
将微服务流程永远绑定到核心
微服务使用L2或L3缓存进行通信谢谢
浏览 9提问于2017-02-17得票数 0
1回答
我读到过：
Akka确保一个参与者的每个实例在它自己的轻量级线程中运行，并且它的消息一次只处理一个。
如果AKKA参与者按顺序处理其消息，那么AKKA如何为单个Actor提供并发性。
浏览 2提问于2016-01-15得票数 2
3回答
我在java中寻找一个消息队列系统，它具有以下属性。
高可用性/无单一故障点(能够使用cassandra作为后端)
确保“交付一次，准确地”一次消息传递。
消息大小没有任意限制(能够处理大小超过1MB的消息)
浏览 1提问于2013-06-24得票数 1
回答已采纳
1回答
我想要构建一个分布式系统，其中我有一个“线程”(一个具有自己ID的消息集合，而不是一个系统进程)，这些消息分布在许多服务器上。这些线程必须具有两个关键属性：
线程中的每一条消息都必须有一个序列号，该序号反映了它在线程中的位置，这是基于时间的。例如，我可以通过在线程#1中说“线程1/ message 10”来获得消息#10。
一旦新消息被添加到线程中，系统就必须能够为它分配一个对所有服务器上的所有线程实例一致的订单号，并且这个编号绝不能改变。
我想知道是否有任何已知的解决方案、库或算法可以帮助我实现第二种选择，因为现在我认为这是一个大问题，因为由于许多因素，不同的服务器可以在不同
浏览 0提问于2013-08-20得票数 4
回答已采纳
1回答
卡夫卡作为未来事件的数据存储
、、、、
我有一个Kafka集群，它根据该源中的数据更改接收来自该源的消息。在某些情况下，消息将在将来处理。所以我有两个选择：
在一个不同的主题(主题名中有日期)下，使用所有打算将来返回给Kafka的消息和post消息，并具有Storm拓扑结构，查找其中包含日期名称的主题。这将确保消息只在其所要处理的日期处理。
将其存储在单独的DB中，并构建一个调度程序，该调度程序只在未来的日期将消息和帖子读入Kafka。
选项1更容易执行，但我的问题是: Kafka是一个持久的数据存储吗？有人对卡夫卡做过这样的事吗？这个设计有什么漏洞吗？
浏览 2提问于2015-01-23得票数 3
Websphere MQ消息是否存储在数据库或文件系统中？我可以将其配置为使用MySQL吗？
浏览 1提问于2011-06-03得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
