我试图把卡夫卡和风暴结合起来,我用卡夫卡喷口从卡夫卡主题中检索数据,并把它送入风暴螺栓进行进一步处理。我能够成功地提交拓扑,但喷口没有发出任何data.It,也不会抛出任何错误。我是卡夫卡和Storm.So的新手,我无法得到这个problem.Please建议的理由,提前modifications.Thanks!我的拓扑:
public static void
嗨,我正在运行一个拓扑,并使用风暴信号发送信息,一次又一次的拓扑。但是我在日志文件中得到了错误。有人能告诉我为什么找不到这门课吗?我的喷水课:public class NumberSpout extends BaseSignalSpout public NumberSpout(String name) {
super(name)