我有一个使用Apache storm创建的拓扑。我已经在适当的地方创建了不同的螺栓和喷嘴来执行各种活动。然而，我计划创建一个自动化测试套件来测试拓扑的功能。
浏览 1提问于2019-05-31得票数 1
我希望接收来自队列的消息，并希望通过Apache存储在Hbase/HDFS等任何数据存储中。我不知道这是否可能。如果是这样的话，如果已经这样做了，是否有人会在相同的(如果不是安慰其他消息提供者)上给出一些提示呢？
浏览 6提问于2016-04-24得票数 0
回答已采纳
1回答
在没有DB insert的情况下，如果我编写一个简单的print语句，我会得到每秒684个元组的吞吐量。我计划运行来自Kafka的100万条记录，并使用mongo insert检查吞吐量。
浏览 25提问于2019-03-06得票数 0
我想在Apache storm运行时，在一个新的jar文件中添加新的逻辑。向它提供新jars的方法是将它们复制到它的extlib。问题是当storm运行时，这个库中的jars被它锁定，并且新的jars不会被加载。它似乎在加载时读取jar类，并且不能在运行时重新读取它们。谁能给我一个关于如何在运行时向Storm添加新jars的提示？
浏览 13提问于2019-01-23得票数 0
有没有人可以解释一下如何将数据从三叉树风暴写入/读取到内存网格(Apache ignite)。我在谷歌上搜索了一下，没有找到任何关于如何从trident storm连接到memory grid的信息/文档。
浏览 5提问于2015-01-01得票数 0
在mongodb中使用Apache Storm 2.1.0时，我在Bolt执行中出现错误： java.lang.NullPointerException at org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:234)
浏览 20提问于2020-11-02得票数 0
我正在我的本地机器上测试storm+kafka集成。我有storm版本1.2.3和Kafka 2.5.0。我使用https://github.com/pvillard31/storm-kafka-kerberos/blob/master/src/main/java/example/KafkaStormKafkaTopology.java中的代码作为我的测试代码。<init&
浏览 157提问于2020-11-27得票数 1
(StormMetricsRegistry.java:74) at org.apache.storm.LocalCluster.-- https://mvnrepository.com/artifact/org.apache.storm/storm-server --&
浏览 14提问于2019-06-16得票数 1
回答已采纳
当我尝试将Kafka集成到我们的暴风拓扑时，我得到了错误的java.lang.ClassNotFoundException kafka.api.OffsetRequest。我的pom.xml <groupId>org.apache.storm</groupId> <scope&
浏览 0提问于2015-07-20得票数 4
2回答
输入文件是由卡夫卡消费者编写的。通过某种方式不移植java中的所有代码，是否有可能将此应用程序移植到火花流中？
浏览 0提问于2016-06-21得票数 0
PS:我正在集成测试我的storm拓扑，我使用kafka和zookeeper作为storm的输入。(NIOServerCnxnFactory.java:123) at clojure.lang.R
浏览 0提问于2016-06-01得票数 1
2回答
我是storm和zookeeper的新手，我导入了项目，想知道编码器使用的zookeeper版本！正如他提到的那样，他使用了storm-0.8.2，但没有提到zookeeper
是否知道他从项目的特定文件夹中使用的zookeeper版本？
浏览 0提问于2015-12-02得票数 0
回答已采纳
6702我用这些ZKSERVER测试了ping，它工作得很好。/storm nimbus命令启动nimbus时，它没有显示任何错误，但也没有结束。
root@69e55d266f5a:/opt/apache-storm-2.2.0/bin:> .-Dstorm.home=/opt/apache-storm-2.2.0 -Dstorm.log.dir=/opt/apache</e
浏览 6提问于2021-02-16得票数 0
KafkaSpout和KafkaBolt对象有什么区别？通常KafkaSpout用于读取卡夫卡制作者的数据，但为什么我们使用KafkaBolt呢？
浏览 0提问于2018-09-03得票数 0
回答已采纳
Version Info: "org.apache.storm" % "storm-kafka-client" % "1.2.1"
在使用该版本的storm时，在运行拓扑时，我看到每个工作人员都有两个进程:一个用于日志写入程序，另一个用于辅助进程，
浏览 1提问于2018-11-09得票数 0
回答已采纳
如何检查Storm是否加载并运行了实际的Storm拓扑，以便在其上进行测试。因为执行集成测试需要等到拓扑运行后才能开始测试逻辑。在本地群集上。
浏览 1提问于2016-03-03得票数 2
在使用新的Kafka版本2.1.0和Storm版本1.2.2开始使用Kafka Spout开始拓扑时，获得了一个java.lang.ClassNotFoundException: kafka.api.OffsetRequest
浏览 16提问于2019-02-07得票数 0
回答已采纳
1回答
我正在尝试运行几个与apache相关的脚本。我通过ssh执行这些命令，所有这些命令都在同一台远程计算机上执行。对某些人来说，这是不正确的。这是我的代码：echo Nimbus started
ssh -i file root@IP 'nohup ./apache-storm-0.9.3/bin/<e
浏览 2提问于2015-07-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
