我在Apache Storm 1.1.0中运行一个简单的Hello World类型的应用程序。应用程序有一个随机整数喷口和一个打印元组输出的螺栓。但不知何故，我无法让它在我的 Windows 系统上工作。
我是 Apache 风暴的新手，并遵循教程。我一直在堆栈溢出中寻找答案，但我找不到任何关于相同的已解决的问题。
以下是我的运行拓扑代码：
public static void runTopology() {
//String filePath = "./src/main/resources/operations.txt";
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("randomNumberSpout", new RandomIntSpout());
builder.setBolt("printingBolt", new PrintingBolt()).shuffleGrouping("randomNumberSpout");
Config config = new Config();
config.setDebug(true);
LocalCluster cluster = new LocalCluster();
try{
cluster.submitTopology("Test", config, builder.createTopology());
}finally{
cluster.shutdown();
}
}
螺栓代码
public class PrintingBolt extends BaseBasicBolt {
/**
*
*/
private static final long serialVersionUID = 1L;
public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
System.out.println("Printing Tupple!!!!");
System.out.println(tuple);
System.out.println("Tupple processed " + tuple.getInteger(1));
basicOutputCollector.emit(new Values(tuple.getInteger(1)));
}
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
outputFieldsDeclarer.declare(new Fields("TestOutput"));
}
}
喷口代码
public class RandomIntSpout extends BaseRichSpout {
/**
*
*/
private static final long serialVersionUID = 1L;
private Random random;
private SpoutOutputCollector outputCollector;
/*@Override
public void open(Map<String,Object> map, TopologyContext topologyContext,
SpoutOutputCollector spoutOutputCollector) {
random = new Random();
outputCollector = spoutOutputCollector;
}*/
public void nextTuple() {
Utils.sleep(1000);
outputCollector.emit(new Values(random.nextInt(), System.currentTimeMillis()));
}
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
outputFieldsDeclarer.declare(new Fields("randomInt", "timestamp"));
}
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
random = new Random();
outputCollector = collector;
}
}
我也可以提供其余的代码，但我认为这不是必需的。如果需要，请在评论中提及，我也会提供。
每当我尝试运行应用程序时，我都会收到以下错误。
10620 [主要] INFO o.a.s.s.o.a.z.ZooKeeper - 正在启动客户端连接，connectString=localhost：2000/storm sessionTimeout=20000> watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@31b0f02 10625 [main-SendThread(0：0：0：0：0：0：0：1：2000)] INFO o.a.s.s.o.a.z.ClientCnxn - 打开与服务器> 0：0：0：0：0：0：0：0：0：0：1/0：0：0：0：0：1：2000。不会尝试使用 SASL 进行身份验证(未知错误) 10627 [主发送线程(0：0：0：0：0：0：0：1：2000)] 信息 o.a.s.s.o.a.z.ClientCnxn - 已建立到> 0：0：0：0：0：0：0：0：1/0：0：0：0：0：0：0：1：2000，正在启动会话 10627 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.s.o.a.z.s.NIOServerCnxnFactory - 接受来自/> 0：0：0：0：0：0：0：0：1：56905 的套接字连接 10628 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - 客户端尝试在/> 0：0：0：0：0：0：0：0：1：56905 处建立新会话 10631 [主发送线程(0：0：0：0：0：0：0：1：2000)] INFO o.a.s.s.o.a.z.ClientCnxn - 服务器> 0：0：0：0：0：0：0：0：0：1/0：0：0：0：0：0：1：2000，会话 ID = 0x16a8e5abd97000d，协商超时 = 20000 10631 [同步线程：0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - 已建立会话 0x16a8e5abd97000d，客户端/> 的协商超时为 20000
0：0：0：0：0：0：0：1：5690510632 [主事件线程] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - 状态更改：已连接 10635 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 处理时出现用户级 KeeperException 会话 ID：0x16a8e5abd97000d 类型：创建 cxid：0x2 zxid：0x26 txntype：-1 reqpath：n/a error path：/storm/blobstoremaxkeysequencenumber> error：KeeperErrorCode = NoNode for/storm/blobstoremaxkeysequencenumber 10655 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 10657 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd97000d 10659 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 10659 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd97000d 已关闭 10661 [main] INFO o.a.s.cluster - setup-path/blobstore/Test-1-1557166474-stormconf.ser/IBMT450PC053RLV.公司CVS.com：6627-1 10660 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] 警告 o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流异常结束 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID> 0x16a8e5abd97000d读取其他数据，可能客户端已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 10671 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/> 0：0：0：0：0：0：0：1：56905 的已关闭套接字连接，该连接具有会话 ID 0x16a8e5abd97000d 10746 [主要] 信息 o.a.s.s.o.a.c.f.i.策展人框架 - 开始 10747 [主要] INFO o.a.s.s.o.a.z.ZooKeeper - 正在启动客户端连接，connectString=localhost：2000/storm sessionTimeout=20000> watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@73893ec1 10755 [main-SendThread(127.0.0.1：2000)] INFO o.a.s.s.o.a.z.ClientCnxn - 打开与服务器 127.0.0.1/127.0.0.1：2000 的套接字连接。>不会尝试使用 SASL 进行身份验证(未知错误) 10756 [主发送线程(127.0.0.1：2000)] INFO o.a.s.s.o.a.z.ClientCnxn - 与 127.0.0.1/127.0.0.1：2000 建立套接字连接，正在启动>会话 10758 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.s.o.a.z.s.NIOServerCnxnFactory - 接受来自/127.0.0.1：56908 的套接字连接 10759 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - 客户端尝试在>/127.0.0.1：56908 建立新会话10766 [主发送线程(127.0.0.1：2000)] INFO o.a.s.s.o.a.z.ClientCnxn - 在服务器 127.0.0.1/127.0.0.1：2000 上完成会话建立，>会话 ID = 0x16a8e5abd97000e，协商超时 = 20000 10766 [同步线程：0] INFO o.a.s.s.s.o.a.z.s.ZooKeeperServer - 已建立会话0x16a8e5abd97000e，客户端>的协商超时为 20000/127.0.0.1：56908 10767 [主事件线程] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - 状态更改：已连接 10778 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 10781 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd97000e 10785 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd97000e 已关闭 10785 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56908 的套接字连接已关闭> 具有会话 ID 0x16a8e5abd97000e 10785 [main] INFO o.a.s.cluster - setup-path/blobstore/Test-1-1557166474-stormcode.ser/IBMT450PC053RLV.公司CVS.com：6627-1 10786 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 10821 [主要] INFO o.a.s.d.nimbus - 达到所需的复制计数 1，conf 密钥的当前复制计数 = 1，代码密钥的当前复制计数> = 1，jar 密钥的当前复制计数 = 1 11042 [主要] 信息 o.a.s.d.nimbus - 激活测试： 测试-1-1557166474 11058 [主要] 信息 o.a.s.d.nimbus - 关闭大师 11064 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11066 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970003 11068 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11069 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] 警告 o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流结束异常 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd970003，客户端可能已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11068 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970003 已关闭 11069 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56875 的套接字连接已关闭，>具有会话 ID 0x16a8e5abd970003 11069 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11072 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970004 11074 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11075 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/> 0：0：0：0：0：0：0：1：56878 的套接字连接已关闭，会话 ID 0x16a8e5abd970004 11074 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970004 已关闭 11077 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.策展人框架 impl - backgroundOperationsLoop exiting 11079 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970000 11081 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970000 已关闭 11081 [主要] 信息 o.a.s.zookeeper - 关闭领导者选举人的动物园管理员连接。 11082 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11082 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56866 的客户端/127.0.0.1：56866>具有会话 ID 0x16a8e5abd970000的套接字连接已关闭 11082 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11084 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970001 11086 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970001 已关闭 11087 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11087 [主要] 信息 o.a.s.d.nimbus - 关闭主控 11087 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11089 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] WARN o.a.s.s.s.o.a.z.s.NIOServerCnxn - 捕获流异常结束 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd970001，可能客户端已关闭套接字at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11089 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56869 的套接字连接已关闭，>具有会话 ID 0x16a8e5abd970001 11090 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970006 11092 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970006 已关闭 11093 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11093 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] WARN o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流结束异常 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd970006，客户端可能已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11094 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56884>的套接字连接已关闭，该客户端具有会话 ID 0x16a8e5abd970006 11095 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11095 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd970008 11098 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd970008 已关闭 11098 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1024,5，main] 赋值设置为 null 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1025,5，main] 赋值设置为 null 11099 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] WARN o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流异常结束 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd970008，客户端可能已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1026,5，main] 赋值设置为 null 11099 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1024,5，main] 为空，当前为空 11099 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1025,5，main] 为空，当前为空 11099 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.a.z.s.NIOServerCnxn - 客户端/> 0：0：0：0：0：0：0：1：56890 的套接字连接已关闭，该连接具有会话 ID 0x16a8e5abd970008 11099 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1026,5，main] 为空，当前为空 11099 [主要] 信息 o.a.s.d.s.主管 - 关闭主管 009e412c-0d39-400c-8302-08296524c703 11100 [线程-10] INFO o.a.s.e.EventManagerImp - 事件管理器中断 11102 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11103 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd97000a 11105 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd97000a 已关闭 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1027,5，main] 赋值设置为 null 11105 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1028,5，main] 赋值设置为 null 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将线程[SLOT_1029,5，main] 赋值设置为 null 11106 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1027,5，main] 为空，当前为空 11106 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1028,5，main] 为空，当前为空 11106 [main] INFO o.a.s.d.s.ReadClusterState - 正在等待线程[SLOT_1029,5，main] 为空，当前为空 11106 [主要] 信息 o.a.s.d.s.主管 - 关闭主管 5daf8496-451f-43ca-b176-b16055d6183c 11106 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] 警告 o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流异常结束org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd97000a，客户端可能已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11106 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.a.z.s.NIOServerCnxn - 客户端/> 0：0：0：0：0：0：0：1：56896 的已关闭套接字连接，该连接具有会话 ID 0x16a8e5abd97000a 11106 [线程-14] INFO o.a.s.e.EventManagerImp - 事件管理器中断 11108 [策展人框架-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11109 [进程线程(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 会话 ID 的已处理会话终止：> 0x16a8e5abd97000c 11112 [主要] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话： 0x16a8e5abd97000c 已关闭 11112 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shutdown 11112 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] 警告 o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流结束异常 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStream异常：无法从客户端会话 ID 读取其他数据> 0x16a8e5abd97000c，可能客户端已关闭套接字 at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java：228) [storm-core-1.1.0.jar：1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java：208) [storm-core-1.1.0.jar：1.1.0] at java.lang.Thread.run(Thread.java：745) [？：1.8.0_60] 11113 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端/127.0.0.1：56902 的套接字连接已关闭> 具有会话 ID 0x16a8e5abd97000c 11114 [主要] 信息 o.a.s.test - 在进程动物园管理员中关闭 11115 [NIOServerCxn.Factory：0.0.0.0/0.0.0.0：2000] INFO o.a.s.NIOServerCnxnFactory - NIOServerCnxn Factory exited run method 11116 [主要] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - 正在关闭 11116 [主要] INFO o.a.s.s.o.a.z.s.SessionTrackerImpl - 正在关闭 11116 [主要] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 正在关闭 11117 [主要] INFO o.a.s.s.o.a.z.s.SyncRequestProcessor - 正在关机 11117 [SyncThread：0] INFO o.a.s.s.o.a.z.s.SyncRequestProcessor - SyncRequestProcessor 退出！ 11117 [ProcessThread(sid：0 cport：-1)：] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - PrepRequestProcessor 退出循环！ 11117 [主要] INFO o.a.s.s.s.o.a.z.s.FinalRequestProcessor - 关闭请求处理器完成 11118 [主要] 信息 o.a.s.test - 在进程 zookeeper 中完成关闭 11118 [主要] INFO o.a.s.test - 删除临时路径 C：\Users\AKHAND~1\AppData\Local\Temp\ae4119b4-70b3-4d04-9aee-5bfae4c4775b 11203 [主要] 信息 o.a.s.test - 删除临时路径 C：\用户\AKHAND~1\AppData\Local\Temp\a78b8c79-b9b3-438d-8df6-5d7bd74281fc 11215 [主要] 信息 o.a.s.test - 无法删除文件：> C：\用户\AKHAND~1\AppData\Local\Temp\a78b8c79-b9b3-438d-8df6-5d7bd74281fc\version-2\log.1 11215 [主要] INFO o.a.s.test - 正在删除临时路径 C：\Users\AKHAND~1\AppData\Local\Temp\0e4fbadc-ad33-4577-9784-4cc163a778fa 11255 [主要] 信息 o.a.s.test - 删除临时路径 C：\Users\AKHAND~1\AppData\Local\Temp\456d6b1d-eb21-4b76-98f1-a2bb44b2aa5e 12197 [会话跟踪器] 信息 o.a.s.s.o.a.z.s.会话跟踪器 - 会话跟踪器插入退出循环！
我无法理解为什么客户端套接字关闭以及为什么会话关闭？我无法让它工作。请帮忙。
我认为您可能需要在此处添加睡眠
try{
cluster.submitTopology("Test", config, builder.createTopology());
//Sleep here
}finally{
cluster.shutdown();
}
当前，您正在提交拓扑，并立即关闭。除非您睡一会儿，否则您的拓扑没有机会运行。