apache-zookeeper - Storm nimbus 如何从 worker 那里得到 ACK？它使用动物园管理员吗？

Question

如何运作？他们是否使用zookeeper来实现这一点？将ACK保存在znode内？ 我正在尝试使用zookeeper构建一个分布式系统，我需要从集群中的各个机器获得确认，200k ack/秒。

是否可以使用zookeeper来做到这一点？

Answer 1

Storm 不使用 Zookeeper 来确认元组，也不将确认发送到 nimbus。它们被直接发送到 spout。

来自guaranteeing message processing页面:

A Storm topology has a set of special "acker" tasks that track the DAG of tuples for every spout tuple. When an acker sees that a DAG is complete, it sends a message to the spout task that created the spout tuple to ack the message.

您需要重写 spout 中的 ack 方法:

@Override
public void ack(Object id) {
    int number = (Integer)id;
    System.out.println(String.format("Spout ack -> %d", number));
}