新消费者是如何使用RabbitMQ中过去产生的信息的？

Question

我是试图运行RabbitMQ的Apache的用户。Kafka支持消费者消费以前产生的任何信息。(通过重新加宽卡夫卡日志中的“偏移”)

我想知道RabbitMQ是否具有相同的功能。(一个新的使用者会在某一点之后请求所有消息。)

Answer 1

我想知道RabbitMQ是否有相同的功能

事实并非如此。

卡夫卡是为这一功能而建立的目标，它是一个事件日志，允许你从某一点出发前进。

RabbitMQ是一个消息队列--先入先出。一旦一条消息被处理，它就会被完成并消失。没有历史或原木可供穿越。

RabbitMQ有一个“近代史”插件，但这并不能提供同样的功能集Kafka。

https://github.com/rabbitmq/rabbitmq-recent-history-exchange#readme

它只允许你说“新的消费者应该得到最后的20条信息，然后才能继续收到新的信息”。

卡夫卡，另一方面，给你一个更广泛的历史和能力，从开始和前进的需要。