StormKafka喷口不发出信息
在我的storm拓扑（有2个喷口和1个bolt）中，其中一个kafka喷口使用者的偏移量正在前进，但MSG没有通过kafka喷口发送到bolt。我可以在storm ui中看到，对于那个特定的喷口，发出和传送的消息是0。所以，我的问题是为什么消费者在前进，我可以看到消费者从zookeeper客户端的抵消逐渐增加。
共有1个答案
后来我发现，出现上述行为的原因是，注册的串行化程序过滤掉了kafka队列中的所有消息，因此没有消息从喷口发出到bolt。这也解释了为什么Kafka主题消费群体的抵销在逐渐增加。
-
一般：我是一个想在Storm/Kafka/Flink/MS Azure SA/Spark上运行一些性能测试（WordCount）的学生。我想使用Kafka经纪人作为输入源。 我使用了Storm-Starter项目中的WordCount示例，并添加了Kafka作为喷口： 我使用kafka-console-producer生成一些消息。我希望有人能帮助我。我是编程Storm的新手...
-
我正在用Apache Storm 1.1.2和Kafka0.11在Java9中构建一个Spring应用程序 我注意到，在高负载（每秒2500条消息）下，Kafka喷口有一个非常高的滞后。Kafka喷口有一个平行性提示3。滞后几乎等于喷口提交的偏移。 这个滞后设置了拓扑每秒可以摄取的最大消息量的上限，这并不是很大。有人知道解决这个问题的办法吗？ 更新：我还注意到，即使有10个工作者和4个并行性提示，
-
我正在使用Storm 1.1.2和Kafka 0.11构建一个Java Spring应用程序，将在Docker容器中启动。 我的拓扑中的所有东西都按计划工作，但在Kafka的高负载下，Kafka滞后会随着时间的推移越来越大。 我的KafKaspoutConfig： 那么我的拓扑结构如下
-
我使用三台机器和本指南在aws集群上设置了一个测试环境。 我在本地模式下测试了我的代码，并使用wirbelsturm创建了一个本地vagrant集群，这两种方法都能产生预期的结果。 当我现在向Web服务器提交代码时，我的喷口和所有的螺栓都是静默的。我的嘴读的是csv，我把它抄送给了灵气和我的主管。storm UI显示我的拓扑为活动的，并显示所有螺栓和我的喷口，但计数器不可见。主管没有已使用得员工.
-
我已经开始使用storm，所以我使用本教程创建简单的拓扑 我的嘴是这样的 我的螺栓是这样的
-
刚开始使用Storm,只是了解喷口的概念,以及如何在喷口中实现并行。