我有一个螺栓，在小批量的元组工作。我基本上有一个 switch 侦听来自上一个螺栓的流或 tick tuple . 它看起来像这样：

switch(component) {
    bolt1:
      do some work...
      anchors.add(tuple)
    tick:
      do some work...
      collector.emit(anchors, value)
      collector.ack(tuple)
      anchors.clear()

当我运行这个程序时，storm ui显示了从这个螺栓中提取的非常少的元组。这是锚定他们的正确方法还是我需要打电话 collector.ack(tuple) 也在bolt switch语句中？尽管storm ui计数很奇怪，但拓扑运行时没有任何元组超时。