我怎么能停止KafkaSpout？

Question

我有一个拓扑，使用KafkaSpout从Kafka读取，然后在rest api中进行POST。问题是API有一些维护周期，因此它在一段时间内不可用，我的问题是如何通过使用kafka spout停止处理消息？我发现了一个名为storm-signals enter link description here的api问题这是我无法改变kafka spout的实现，使其继承BaseSignalSpout。还有其他办法吗？

Answer 1

只需停用拓扑即可。您可以通过Storm CLI，Storm UI，Storm REST API或Nimbus客户端（Java或其他）来完成此操作。在重新激活拓扑之前，喷口将停止喷射。