在apachestorm拓扑中,喷口和螺栓之间是否有内部队列?

b1zrtrql  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(300)

为了符合特定的rabbitmq消息代理实现,喷口尽可能快地使用和确认广播消息是至关重要的。
messagebroker示例的规范坚持这样一个事实:使用者必须实现内存队列,以便在处理时间缓慢的情况下不延迟确认。
在喷口和插销之间有这样一个隐含的队列吗?我必须在bolt中实现内存队列吗?

q3qa4bjr

q3qa4bjr1#

在喷口和螺栓之间有一个队列,如这里所述。
如果这对您没有帮助,您可以在spout和ack中创建一个内部缓冲区,只要您在该内部缓冲区中插入元组。

相关问题