java - 是否可以通过 spout 或 bolt 停用和重新激活 Storm 拓扑？

Question

当满足某些条件时，比如遇到一种特殊类型的元组，我想停用拓扑。这可以在 spout/bolt 中完成吗？如果是，是否有任何方法可以从 spout/bolt 重新激活拓扑？

Answer 1

我已经在下面的代码中添加了所有三个 Action 来激活/停用/终止。这可以从独立的 java 代码(在 spout/bolt 之外)调用。

从 spout 或 bolt 停用很简单，但重新激活会很棘手，因为一旦停用，您的 spout/bolt 就不会主动运行 java 程序。

import backtype.storm.generated.KillOptions;
import backtype.storm.generated.Nimbus.Client;
import backtype.storm.utils.NimbusClient;
import backtype.storm.utils.Utils;

Client client = NimbusClient.getConfiguredClient(Utils.readStormConfig()).getClient();

client.activate(topologyName);
client.deactivate(topologyName);

KillOptions killOpts = new KillOptions();
killOpts.set_wait_secs(30);
client.killTopologyWithOpts(topologyName, killOpts);