在 Apache Storm 拓扑中,spout 和 bolt 之间是否存在内部队列?

In an Apache Storm topology, is there an internal queue between a spout and a bolt?

为了符合特定的 RabbitMQ 消息代理实现,spout consume critical并尽快 确认广播消息。

Message Broker 实例的规范坚持这样一个事实,即消费者必须在内存中实现队列,以便在处理时间较慢的情况下不会延迟确认。

在 spout 和 bolt 之间是否有这样的隐式队列?我必须在 bolt 中实现内存队列吗?

spouts 和 bolts 之间有一个队列,as stated here

如果这对您没有帮助,您可以在 spout 中创建一个内部缓冲区,并在将元组插入该内部缓冲区后立即确认。