在 rabbitmq 流中添加延迟消费消息

Question

我正在使用 rabbitmq 流，我需要在消息之间添加延迟，因为流处理消息的速度非常快。

我该怎么做？

Answer 1

编辑 RabbitMQ 流本身可以更快地发送消息，但有一种信用机制可以避免消费者节流。 客户端发送信用以获得更多消息。 目前这个功能还没有公开，我们正在研究它，所以当你 produce/consume 消息时，atm 这是你需要做的事情 client-side。