在 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 中创建一个内部缓冲区,并在将元组插入该内部缓冲区后立即确认。
为了符合特定的 RabbitMQ 消息代理实现,spout consume critical并尽快 确认广播消息。
Message Broker 实例的规范坚持这样一个事实,即消费者必须在内存中实现队列,以便在处理时间较慢的情况下不会延迟确认。
在 spout 和 bolt 之间是否有这样的隐式队列?我必须在 bolt 中实现内存队列吗?
spouts 和 bolts 之间有一个队列,as stated here。
如果这对您没有帮助,您可以在 spout 中创建一个内部缓冲区,并在将元组插入该内部缓冲区后立即确认。