一个ack/fail机制问题

来源：9-3 -Storm的ack和fail机制

BingleyFeng

2018-07-15

spout用emit发射数据的时候，参数msgid，bolts接受。如果有10个bolt级联，msgid在bolt之间传递的时候是否会变化？bolt发射数据给下一个bolt时候，需要写mgsId吗？

写回答

1回答

Michael_PK

2018-07-16

已采纳

我们现在的做法是，只管spout出来的msgid，后续的不处理，只要后续流程不对就会重新处理

BingleyFeng

非常感谢！

2018-07-17

共3条回复

Java大数据实战，巧用Storm快速切入实时流处理领域

深入Storm内部机制，logstash+kafka，快速切入大数据实时流处理

518 学习 · 143 问题

相似问题

回答 1

回答 1

回答 1

回答 2

回答 2