如何让一个喷子伺候另一个喷子？
如有任何帮助，我们将不胜感激。
共有1个答案
只需选择喷口A与喷口B的通信方式即可：
>
用另一个Kafka的题目。当Spout A结束时，它会产生一个消息到一个特殊主题，Spout B在开始从主要主题读取之前等待该主题的消息。
使用写入Zookeeper（或HDFS、HBase等）的标志来指示喷口a已完成
-
“Kafka spout”和“Kafka Consumer”都从Kafka经纪人那里检索数据，到目前为止我知道的spout是用来与Storm通信的，而Consumer是用来与其他任何东西通信的。 --但是，技术上的区别是什么？ -或者，如果我使用Consumer提取数据，然后使用“Storm Spout”接收数据，和如果我只是使用“Kafka Spout”，然后将其添加到我的Storm拓扑构建器的
-
我有一个关于接口的问题，比如： 现在，我需要这只猫去抓一只老鼠void catchMouse（）{std：：cout 有几种可能的解决方案，但看起来都不好。 > 在IAnim中添加一个方法，然后使用AnimalFactory创建猫后，我可以从IAnimal调用catchMouse（）方法。但是catchMouse并不适用于所有动物，狗不catchMouse。将方法添加到IEM会污染界面，嗅到代码。
-
我们来把increment函数转换为成员函数。我们再次将其中一个参数变成this。然后检查整个函数并使所有变量被隐式访问。 void Time::increment (double secs) { second += secs; while (second >= 60.0) { second -= 60.0; minute += 1; } while (m
-
我还不明白的是，喷口是否也是这样。如果一个spout发出一个元组（即，spout中的函数被执行），并且spout运行的计算机在此后不久崩溃，该元组会被zookeeper复活吗？还是我们需要Kafka来保证这一点？ 附注。我理解，在对的调用中，必须为spout发出的元组分配唯一的ID。 P.P.S.我在书中看到的示例代码使用之类的东西来跟踪哪些喷出的元组尚未被加密。这是不是自动被Zookeeper坚
-
读了这篇文章后，我试着使用Google Guice：http://tech.puredanger.com/2007/07/03/pattern-hate-singleton/ 但有一点我不明白：当您使用Guice的@Singleton Anotion时，注入注入相同的实例，但只针对一个注入。 如果我在其他地方创建了另一个注射器，@Singletion不起作用（如留档中所述）。 因此，我必须在代码中
-
当一个标记接触到另一个标记时，我如何使一个条件被执行？我会这样做： 但不管用。我是不是忘了什么？您好，Tjovo工作室