如何在BaserichSpout-Apache Storm的fail（）方法中找到失败的根源？

Question

我有一个如下的拓扑：

Spout --> Bolt 1 --> Bolt2 --> Bolt3

其中Spout有一个由Bolt2订阅的流“MyStream”，而其他流“Bolt1Stream”是Bolt1接收元组的地方。

提前致谢

Answer 1

对于每个流，我使用一个单独的类来标识流。另一种方法是使用相同的类，并在类中有一个整数或枚举来标识流。

@Override
public void fail(Object msgId) {
   if (msgId instanceof MyTupleClass) {
   // Default stream   
   MyTupleClass oneTuple = (MyTupleClass) msgId;
   //---tuple replay logic. Re-emitting the failed tuples    
   ReEmitTheDefaultStreamTuple(oneTuple);
}
else {
   //it's the other stream
   //For this stream you could perhaps use MySecondTupleClass
}