在Apache Storm中使用LocalCluster和StormSubmitter创建拓扑有什么区别？
在Apache Storm中，使用LocalCluster和StormSubmitter创建拓扑有以下区别：
- LocalCluster：LocalCluster是用于本地开发和调试Storm拓扑的工具。它允许在本地运行Storm集群，模拟真实的分布式环境。使用LocalCluster创建的拓扑在本地运行，不需要连接到远程集群。这对于开发人员来说非常方便，可以快速测试和调试拓扑逻辑。
- StormSubmitter：StormSubmitter用于将Storm拓扑提交到远程Storm集群中运行。它将拓扑打包成一个可执行的JAR文件，并将其提交到远程集群的Nimbus节点。StormSubmitter提供了一种将拓扑部署到生产环境的方式，可以实现高可用性和可伸缩性。
区别总结：
- LocalCluster适用于本地开发和调试，而StormSubmitter适用于将拓扑提交到远程集群中运行。
- LocalCluster在本地运行拓扑，不需要连接到远程集群，而StormSubmitter将拓扑提交到远程集群的Nimbus节点。
- LocalCluster方便开发人员快速测试和调试拓扑逻辑，而StormSubmitter提供了一种部署拓扑到生产环境的方式。
对于Apache Storm的更多信息和使用方法，可以参考腾讯云的相关产品和文档：
相关·内容
我把风暴安装在一个服务器上。我确信动物园管理员、nimbus、主管和ui服务都在正常运行，因为我可以看到这些进程，也可以从浏览器中查看UI。暴java代码可以像预期的那样在eclipse中运行，您可以引用下面的代码来找出本地模式和远程模式的不同之处。
if(args.length == 0)
{
LocalCluster cluster = new LocalCluster();
cluster.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());
Utils.w
浏览 2提问于2016-08-30得票数 0
我正在尝试将ExclamationTopology示例提交到一个单一节点集群中，并获得以下错误
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.TApplicationException: Internal error processing beginFileUpload
at org.apache.storm.StormSubmitter.submitJarAs(StormSubmitter.java:507)
at org.apache.storm.StormSub
浏览 4提问于2019-11-25得票数 1
我刚刚实现了一个三叉树DRPC函数来处理传入的消息，并且我正在尝试将拓扑的最后阶段处理的元组的计数持久化为三叉树状态。下面是我的拓扑结构：
topology.newDRPCStream("portfolio")
.map(parseMapFunction,
new Fields("portfolioUrn", "portfolioSourceSystem", "portfolioRegion",
"portfolioTimestamp", "portfolio
浏览 4提问于2019-06-12得票数 0
这是我第一次使用Apache，我有以下问题。对于我的应用程序，我有这样的要求:对于使用我的应用程序的每个用户来说，拓扑图是不同的，而且每个用户也可以有多个拓扑图。
因此，我的想法是使用拓扑生成器动态创建拓扑图。例如，使用“风暴”中的图例，只需：
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("1", new TestWordSpout(true), 5);
builder.setSpout("2", new TestWordSpout(true), 3);
builder.s
浏览 3提问于2015-11-29得票数 1
回答已采纳
1回答
我是Apache Storm的新手，我正在尝试创建storm中的拓扑，可以用于流的实时处理。但是，当我尝试在本地群集上提交拓扑时，我得到了以下异常
Exception in thread "main" java.lang.ExceptionInInitializerError
at clojure.lang.Namespace.<init>(Namespace.java:34)
at clojure.lang.Namespace.findOrCreate(Namespace.java:176)
at clojure.lang.Var.internPrivate(Va
浏览 7提问于2019-02-25得票数 0
我正在阅读卡夫卡消费者的数据到风暴喷口。但是，当我重新启动Storm时，它也会读取之前处理过的Kafka记录。在重新启动时，我不想处理以前处理过的记录。这是我的代码：
public class KafkaStormSample {
public static void main(String[] args) throws Exception {
SpoutConfig kafkaSpoutConfig = new SpoutConfig(hosts, topic, "/" + topic, UUID.randomUUID().toString());
浏览 0提问于2019-08-25得票数 2
回答已采纳
我想实例化一个LocalCluster()，并阻止它运行自己的嵌入式zookeeper，而使用我的。
关于这个问题："“这个问题已经在0.9.3版本中解决了。
我能有一个这样的示例代码吗？
PS:我正在集成测试我的storm拓扑，我使用kafka和zookeeper作为storm的输入。当我没有为localcluster指定zookeeper信息时，我在"LocalCluster localCluster = new LocalCluster()“行得到这个异常：
2016-06-08 12:16:56,785 WARN [Thread-30] jmx.MBeanRegist
浏览 0提问于2016-06-01得票数 1
3回答
目前，我在Windows机器上使用Netbeans开发拓扑。当我以本地模式部署时：
LocalCluster cluster = new LocalCluster(); cluster.submitTopology("word-count", conf, builder.createTopology());
一切都很好，但当我试图：
StormSubmitter.submitTopology("word", conf, builder.createTopology());
显然，它试图在集群模式下部署拓扑，但是失败了，因为我没有在本地计算机上运行storm ni
浏览 8提问于2014-09-04得票数 4
回答已采纳
2回答
在进行基于读取Apache文件并对其进行处理的第一个Storm拓扑时，提交Topology时出现了奇怪的错误：
6044 [main] WARN backtype.storm.daemon.nimbus - Topology submission exception. (topology name='apachelog') #<InvalidTopologyException InvalidTopologyException(msg:Component: [lineBolt] subscribes from non-existent component [line])&
浏览 5提问于2014-01-21得票数 5
回答已采纳
我已经建立了一个项目，试图运行标准的"ExclamationTopology“在内存中的风暴版本，由IntelliJ IDE触发。这就是我的POM.xml：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLoca
浏览 1提问于2018-02-25得票数 0
回答已采纳
我已经设置了storm拓扑(1 worker)，其中spout(在java中)从redis出队(使用blpop)事件并传输到bolts。但一个观察是，当存在超过200万个队列，并且在风暴nimbus/supervisor/zookeeper/worker日志中没有发现警告/异常时，一些事件没有接收到闪存(在clojure中，6-spout线程，50-bolt线程)。
在本地，此方案不使用虚拟数据进行复制。在集群中没有看到网络延迟/丢包。平均处理延迟为100ms。如何在生产中找到原因来修复它。
(ns event-processor
(:import [backtype.storm Stor
浏览 10提问于2018-09-05得票数 1
回答已采纳
4回答
嗨，我有一个运行风暴集群的问题。它类似于
我的拓扑定义为：
package com.abc.newsclassification;
import StormBase.KnowledgeGraph.ClassifierBolt;
import StormBase.KnowledgeGraph.ClientSpecificTwitterSpout;
import StormBase.KnowledgeGraph.LiveTwitterSpout;
import StormBas
浏览 2提问于2014-03-08得票数 1
我们在LocalCluster中执行一个风暴拓扑。Storm拓扑执行正常，并且能够连接Storm UI (8090)。但是Storm UI没有显示正在运行的拓扑信息。
LocalCluster cluster = new LocalCluster();
并提交如下内容：
bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.twitter.TwitterTopologyCreator Twitter
浏览 0提问于2016-05-05得票数 4
1回答
我正在尝试调试非常简单的拓扑(1口1螺栓)
public class JoinerTopologyTest {
public static void main(String[] args) throws IOException {
Config conf = new Config();
conf.setNumWorkers(5);
conf.setDebug(true);
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("SPOUT-1",new My
浏览 1提问于2016-07-14得票数 2
回答已采纳
我终于想到我有一个图论，写在一个红色数据库上。我有一个螺栓要打印，一个螺栓要插入到红色。但是，当我试图启动拓扑时，会出现以下错误：
...5333 [main-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED
5376 [main] INFO b.s.d.supervisor - Starting supervisor with id 1917ef54-0f16-47b8-86ea-b6722aa33c68 at host amnor-A88XPLUS
5405 [mai
浏览 9提问于2016-01-28得票数 0
回答已采纳
使用下面的Q&A，我设法通过Apache集群上的eclipse (在本地运行)启用了调试。
我的conf/storm.yaml有以下行来启用在工作节点上的调试：
worker.childopts: "-agentlib:jdwp=transport=dt_socket,address=8000,server=y,suspend=y"
当我提交一个Topology来运行的时候(在集群中)，我可以在我的编辑器中设置断点和查看变量。
但是当我尝试在本地(在中)运行它时，我似乎无法通过eclipse连接(连接被拒绝)。
# I'm using storm crawler
浏览 6提问于2015-09-04得票数 1
回答已采纳
1回答
我是apache和kafka的新手，我试着通过OpenClassroom.The原理提供的课程来学习这些概念，通过python程序将消息发送到kafka服务器，并通过storm拓扑的主类中定义的kafka喷口检索消息。问题是我不明白螺栓是如何检索消息的。据我所知，这是在ParsingBolt类中使用以下代码行完成的：JSONObject obj = (JSONObject)jsonParser.parse(input.getStringByField("value"));。唯一的问题是，我不明白我们如何知道消息包含在value字段中。下面可以找到main类和parsing bo
浏览 21提问于2022-06-13得票数 0
回答已采纳
2回答
我采用了示例字数统计代码，并尝试在不提交到LocalCluster.的情况下提交到远程nimbus服务器。我在客户端使用了以下代码，并使用了以下yaml配置，服务器和ZK分别启动。
当我在客户端使用下面的代码提交时，当我运行./storm jar文件/path/jar-file.jar时，我得到了以下错误
ut.pending":5000,"storm.zookeeper.servers":"149.160.221.43","topology.max.task.parallelism":3}
308 [main] WARN backt
浏览 0提问于2014-12-04得票数 4
我目前正在学习如何使用apache-storm和apache-kafka。我试图通过在pom中添加其他依赖项来解决这个问题，但我找到的所有解决方案都与apache-spark-streaming相关。您可以在code和pom下面找到。
the code
package analytics;
import java.util.Properties;
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.StormSubmitter;
import org.ap
浏览 12提问于2022-06-07得票数 0
回答已采纳
该算法使用KafkaSpout从卡夫卡队列中读取数据。
我正面临以下例外情况：
Exception in thread "main" java.lang.IllegalStateException: Couldn't initialize the topology
at com.bridgera.iot.kafka.App.main(App.java:63)
Caused by: java.lang.IllegalArgumentException: Storm conf is not valid. Must be json-serializable
at ba
浏览 0提问于2015-12-17得票数 1
1回答
Storm UI拓扑不工作
、、、、
我们在LocalCluster中执行一个风暴拓扑。Storm拓扑执行正常，并且能够连接Storm UI (8090)。但是Storm UI没有显示正在运行的拓扑信息。
LocalCluster cluster = new LocalCluster();
并提交如下内容：
bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.twitter.TwitterTopologyCreator Twitter
浏览 5提问于2016-05-05得票数 1
我尝试在Ubuntu 14.04中设置我的storm DRPC开发环境。我已经设置了Zookeeper，Nimbus，drcp服务器，supervisor，ui，并使它们运行并提交拓扑。
然后我有以下名为NodeClient.js的node.js客户端代码，当我尝试运行nodejs NodeClient.js时，什么也没有发生。我的Nodejs客户端出了什么问题，或者其他地方出了问题。
。我认为client.execute会将"hello world“数据包发送到storm队列。我说的对吗？
========================NodeClient.js======
浏览 1提问于2015-03-23得票数 0
1回答
当我试图提交拓扑时，我发现
Exception in thread "main" java.lang.RuntimeException: Found multiple defaults.yaml resources. You're probably bundling the Storm jars with your topology jar.
at backtype.storm.utils.Utils.findAndReadConfigFile(Utils.java:115)
at backtype.storm.utils.Utils.readDefaultConfig
浏览 1提问于2015-10-26得票数 7
回答已采纳
1回答
风暴创建拓扑
、、
我正在尝试使用Eclipse在Linux中运行storm starter示例。我收到以下错误，并且从未调用过nexttuple函数。
错误：
35979 [main] INFO o.a.s.d.supervisor - Shutting down supervisor cfba8fc6- 81e6-47cb-b8b9-ec7c700f4dfe
35981 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN o.a.s.s.o.a.z.s.NIOServerCnxn - caught end of stream exception
org.
浏览 2提问于2016-04-14得票数 0
I am using Leiningen 2.5.3 on Java 1.7.0_79 OpenJDK 64-Bit Server VM.
我想用lein uberjar排除风暴核心罐。下面是我的project.clj
(defproject kafka2hdfs "0.1.0-SNAPSHOT"
:description "FIXME: write description"
:url "http://example.com/FIXME"
:license {:name "Eclipse Public License"
浏览 3提问于2015-11-02得票数 1
回答已采纳
我在ubuntu 12.04上运行storm和rabbitmq。rabbitmq正在发送由storm spout接收的数据。我使用StormSubmitter类来指定一个集群。
我正在使用command> bin/storm jar Rabbitmqstorm.jar RabbitmqTopology rabbittest来运行storm拓扑。
但是我在线程"main“java.lang.NoClassDefFoundError中得到了一个异常异常: com/rabbitmq/client/Consumer
当我使用LocalCluster类时，这个命令工作得很好。但是，我想在集
浏览 0提问于2014-04-07得票数 1
下面的设计可以在Storm中完成吗？
让我们以下面的中出现的wordcount为例，我将单词生成器spout更改为文件阅读器spout
这个单词统计拓扑的设计是1.输出读取文件并逐行创建句子2.螺栓将句子拆分为单词3.螺栓添加唯一的单词并给出单词及其对应的计数
因此，在某种程度上，拓扑描述了一个文件需要采用的流，以统计它所拥有的唯一字。
如果我有两个文件file1和file2，其中一个应该能够调用相同的拓扑，并创建该拓扑的两个实例来运行相同的字数统计。
为了跟踪字数统计是否确实已经完成，一旦文件被处理，字数统计拓扑的实例应该具有已完成状态。
在目前的Storm设计中，我发现Topology是实
浏览 1提问于2015-12-23得票数 0
1回答
我用Storm开发了一个流处理项目。我创建了一个拓扑，并通过执行项目的Main类来运行它。
在Storm教程中，我看到了一个从8080端口访问的UI，它显示了喷口和螺栓的详细信息。但是，我找不到启动UI的方法。我怎么能这么做？
pom.xml文件：
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>1.2.2</version>
<sc
浏览 0提问于2019-05-26得票数 1
回答已采纳
这是一个默认配置，就像在示例中一样，没有任何更改。我只是想让这个基本的例子起作用。
我正在尝试运行Storm 1.2.2中的示例。我构建了storm-starter项目，并尝试使用以下命令行执行：
storm jar target/storm-starter-1.2.2.jar org.apache.storm.starter.ExclamationTopology -local
但是，我得到了以下异常：
apara:storm-starter aparansky$ storm jar target/storm-starter-1.2.2.jar org.apache.storm.starte
浏览 3提问于2018-06-15得票数 0
我是Storm的新手，并创建了一个程序来读取某个时间递增的数字。我在Spout中使用了一个计数器，在"nextTuple()“方法中，计数器被发出并递增。
_collector.emit(new Values(new Integer(currentNumber++)));
/* how this method is being continuously called...*/
在执行()中，元组类的方法具有
public void execute(Tuple input) {
int number = input.getInteger(0);
logger.info("Thi
浏览 3提问于2013-12-05得票数 9
回答已采纳
我试着写一个简单的Storm + Camel项目。我的Storm拓扑分析tweet和一个螺栓应该发送tweet文本到apache骆驼路由，这反过来是使用websocket通知一些webapp。
我无法使它工作，因为NotSerializableExceptions从螺栓接收时，试图使用构建一次CamelContext。
我已经尝试过的是：
在螺栓的构造函数中传递CamelContext -在NotSerializableException中的结果
在暴风雨中通过CamelContext，并用于螺栓的准备(.)方法对gian进行访问。在以下方面的成果：
14484主要错误org.apac
浏览 4提问于2015-04-28得票数 3
回答已采纳
我正在使用Apache Storm 0.9.4。我设置了一个5节点集群，它运行得很好。(实际上，5个主管在5个不同的物理节点上充当码头容器。)
我的环境在这里
$cat /etc/redhat-release
CentOS release 6.6 (Final)
$docker -v
Docker version 1.4.1, build 5bc2ff8/1.4.1
$java -version
java version "1.7.0_79" OpenJDK Runtime Environment
(rhel-2.5.5.1.el6_6-x86_64 u79-b14) O
浏览 9提问于2015-04-28得票数 1
回答已采纳
我有一个问题，正在执行一个样本来连接storm和kafka。我成功地让kafka运行起来了。下一步将是连接storm。 这是示例代码。 /**
* @author Amit Kumar
*/
public class Topology {
private static final Logger LOG = Logger.getLogger(Topology.class);
public static void main(String[] args) {
// Build Spout configuration using input command
浏览 34提问于2019-06-10得票数 0
回答已采纳
1回答
我是storm的新手，我提交了storm-starter项目，Word-count Topology
我得到了
Acked是零！我怎么才能修复它？
任何不知道该项目的人的代码链接
package storm.starter;
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.StormSubmitter;
import backtype.storm.task.ShellBolt;
import backtype.storm.topology.BasicOutp
浏览 0提问于2016-01-20得票数 0
这是我试图运行的基本字数拓扑。但是我收到的错误是'INFO org.apache.storm.zookeeper.server.SessionTrackerImpl - SessionTrackerImpl exited loop!‘。有人能帮我吗？？
当我删除cluster.shutdown()时，tweet接连不断，直到我按下cntrl+c。
import java.util.Arrays;
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import bac
浏览 0提问于2017-04-19得票数 0
我使用springboot和storm来做一个演示，它在本地模式下工作，但在提交jar时在集群模式下报告错误 ./storm jar storm-demo3-0.0.1-SNAPSHOT.jar org.springframework.boot.loader.JarLauncher simpleBoot 当我使用maven- springBoot -plugin移动编译器并打包时，它可以很好地工作 <build>
<plugins>
<plugin>
<groupId>or
浏览 31提问于2019-05-22得票数 1
1回答
我可以用本地集群运行storm Kafka，但不能用storm Submitter运行下面是我的拓扑代码
有人能帮我解决这个问题吗:)
package com.org.kafka;
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.generated.AlreadyAliveException;
import org.apache.storm.generated.AuthorizationException;
import org.apache.storm
浏览 6提问于2018-01-24得票数 0
在向集群提交风暴拓扑时，我收到此错误。
6653 [main] INFO backtype.storm.daemon.supervisor - Starting supervisor with id 8ee90770-957a-40c7-a70b-fd7399cab6a1 at host Ritesh-RM
6706 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar...
6711 [main] INFO backtype.storm.StormSubmit
浏览 2提问于2015-09-15得票数 3
2回答
我正在尝试使用Eclipse在远程主机上提交Storm拓扑。
这是我的代码：
Config conf = new Config();
conf.setDebug(false);
conf.setNumWorkers(1);
conf.put(Config.NIMBUS_HOST, "hostName");
conf.put(Config.NIMBUS_THRIFT_PORT,6627);
conf.put(Config.STORM_ZOOKEEPER_SERVERS,Arrays.asList(new String[]{"hostName"}));
conf.p
浏览 7提问于2015-10-16得票数 2
回答已采纳
我正在尝试向我的风暴集群提交一个拓扑，在运行mvn包时我得到了以下错误
[INFO] Scanning for projects...
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building storm-starter 0.0.1-SNAPSHOT
[INFO]
浏览 1提问于2014-08-19得票数 0
回答已采纳
我使用R螺栓来处理我的数据，我想将处理后的数据从R螺栓发送到我的下一个螺栓，即当从R螺栓发出CountBolt.But时，不能将java.lang.String转换为java.util.List错误。
ERROR o.a.s.t.ShellBolt - Halting process: ShellBolt died. Command: [Rscript, permute.R], ProcessInfo pid:7169, name:python-split-sentence exitCode:-1, errorString:
java.lang.ClassCastException: ja
浏览 0提问于2019-04-08得票数 0
目前我正在进行一个项目，以获取来自TI-SensorTag CC2650的传感器值，通过HTTP (通过)将这些值与python脚本发送到Apache，并将Kafka与Apache连接起来处理数据。
这些数据将通过拓扑中的一个螺栓写入我的本地系统(Apache集群文件夹的目录)上的..txt文件。
几周前，我刚从Storm和Kafka开始，我对以下几点感到困惑：
如果我在本地集群上运行拓扑，一切都会正常工作。但是，如果我将它提交到一个运行在localhost上的“正常”集群中:8888，那么它就什么也不做了。
Storm确实显示了拓扑结构，但似乎对来自kafka的传入消息没有任何反应。
本地集
浏览 2提问于2016-12-05得票数 1
回答已采纳
当我在IntellijIdea或Eclipse上启动一个简单的Strorm脚本时，我会遇到这样的问题：“无法规范化地址localhost/:2000，因为它无法解决”。
import org.apache.storm.*;
import org.apache.storm.generated.*;
import org.apache.storm.spout.SpoutOutputCollector;
import org.apache.storm.task.OutputCollector;
import org.apache.storm.task.TopologyContext;
import
浏览 6提问于2022-01-03得票数 -1
1回答
我试图用JoinBolt将两个卡夫卡数据流(使用卡夫卡喷口)连接成一个数据流，并使用下面的代码片段()
它说，JoinBolt的每个传入数据流都必须是在单个字段上分组的字段。流只应使用其上为FieldsGrouped的字段与其他流连接。
代码片段：
KafkaSpout kafka_spout_1 = SpoutBuilder.buildSpout("127.0.0.1:2181","test-topic-1", "/spout-1", "spout-1");//String zkHosts, String topic,
浏览 1提问于2018-08-22得票数 0
回答已采纳
我正试图在编译并运行storm-kafka-starter项目。
KafkaTopology的主要功能如下所示：
public class KafkaTopology {
public static void main(String[] args) throws Exception {
List<String> hosts = new ArrayList<String>();
hosts.add("localhost");
SpoutConfig kafkaConf = new SpoutConfig(StaticHost
浏览 4提问于2013-07-23得票数 3
回答已采纳
我目前正在学习如何使用apache和apache，通过遵循OpenClassRoom提供的课程，我的问题非常类似于我们可以找到的和.I试图用这些帖子上提供的信息来解决我的问题，但是没有任何改变，我仍然有同样的错误。
我可以在eclipse上编译代码，并且可以使用mvn package命令，没有任何问题。我把我找到的所有信息都放到了kafka和storm的pom.xml里。任何建议都会对我有很大帮助。您可以找到下面的pom和代码。
The pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<proje
浏览 5提问于2022-05-30得票数 1
回答已采纳
我正在尝试使用intellij运行风暴拓扑。到今天为止，拓扑运行得很好，但今天每次我尝试运行它时，我都会收到以下错误：
Error:maven-resources-test:twitter_storm_new: java.lang.NegativeArraySizeException
有没有人能说出有没有办法解决这个问题？
下面是我的拓扑代码：
public class AuthorsAndFeaturesTopology {
public static final String PATH_TO_AUTHORS_AND_FEATURES_FILE="/home/christina
浏览 0提问于2016-06-29得票数 3
我尝试了几个配置参数，甚至没有运气地使用withLocalModeOverride。我在这里错过了什么？
这里有一个示例应用程序，在30岁以后，计数器被重置，一切都重新启动。如果我能提供更多的细节，请告诉我。
用法：
mvn package
java -jar target/Test-0.1.0.jar
src/main/java/Test.java
package storm.test;
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.generate
浏览 8提问于2019-10-02得票数 0
回答已采纳
我正在本地开发一个风暴拓扑。我正在使用Storm0.9.2-孵化，并开发了一个简单的拓扑。当我使用LocalCluster()选项部署它时，它工作得很好，但是它不会出现在我的Storm中--它只是执行。
当我定期部署它时，它将显示我的Storm中的拓扑，但是当我单击它时，没有一个喷口或螺栓是可见的。
我也尝试了这个例子，WordCountTopology，在许多风暴启动项目。同样的行为也会发生。
我的问题是，为什么喷口和螺栓没有出现？如果您在不使用LocalCluser()选项的情况下在本地部署拓扑，这会导致问题吗？是否有可能在我的本地盒上部署一个拓扑，并在Storm中看到它与所有的喷口和螺栓
浏览 0提问于2015-02-20得票数 1
回答已采纳
1回答
我集成了Apache Storm 1.0.3和Apache Kafka_2.11-0.10.1.0。Storm正确地阅读了kafka主题中的一到两个menssage，但当第一个螺栓确认元组时，此确认不会在Storm UI中显示。有什么问题吗？
其他问题:当Storm阅读来自kafka主题的10或19条消息时，在这一点上，Storm UI显示20为Bolt，如果阅读其他19条消息，则添加20多条。我不明白为什么Storm UI在20中显示Spout和bolts的acked。谁能解释一下在Storm Ui控制台中注册acked和fail的逻辑是什么？
我的拓扑配置是：
final Topology
浏览 3提问于2017-03-23得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
