文件名称：storm利用ack保证数据的可靠性源码
文件大小：13.57MB
文件格式：ZIP
更新时间：2020-10-30 04:59:04
storm ack
storm利用ack保证数据的可靠性，发送失败时进行重发，保证数据不丢失。
【文件预览】：
Storm-ACK
----src()
--------Topology()
--------Bolt()
--------Spout()
----bin()
--------Topology()
--------Bolt()
--------Spout()
----.classpath(3KB)
----.settings()
--------org.eclipse.jdt.core.prefs(598B)
----.project(385B)
----lib()
--------reflectasm-1.07-shaded.jar(64KB)
--------httpcore-4.1.jar(177KB)
--------commons-io-1.4.jar(106KB)
--------commons-logging-1.1.1.jar(59KB)
--------compojure-1.1.3.jar(6KB)
--------commons-lang-2.5.jar(273KB)
--------commons-fileupload-1.2.1.jar(56KB)
--------tools.cli-0.2.2.jar(3KB)
--------storm-0.8.2.jar(4.83MB)
--------slf4j-log4j12-1.5.8.jar(9KB)
--------zookeeper-3.3.3.jar(588KB)
--------junit-3.8.1.jar(118KB)
--------ring-servlet-0.3.11.jar(3KB)
--------tools.logging-0.2.3.jar(7KB)
--------clout-1.0.1.jar(3KB)
--------objenesis-1.2.jar(35KB)
--------clj-time-0.4.1.jar(9KB)
--------jgrapht-0.8.3.jar(240KB)
--------carbonite-1.5.0.jar(57KB)
--------curator-framework-1.0.1.jar(97KB)
--------log4j-1.2.16.jar(470KB)
--------jetty-util-6.1.26.jar(173KB)
--------slf4j-api-1.5.8.jar(23KB)
--------libthrift7-0.7.0.jar(295KB)
--------joda-time-2.0.jar(556KB)
--------ring-core-1.1.5.jar(21KB)
--------servlet-api-2.5-20081211.jar(131KB)
--------commons-exec-1.1.jar(51KB)
--------asm-4.0.jar(45KB)
--------hiccup-0.3.6.jar(8KB)
--------core.incubator-0.1.0.jar(3KB)
--------servlet-api-2.5.jar(103KB)
--------jline-0.9.94.jar(85KB)
--------snakeyaml-1.9.jar(260KB)
--------guava-13.0.jar(1.8MB)
--------disruptor-2.10.1.jar(50KB)
--------jzmq-2.1.0.jar(13KB)
--------math.numeric-tower-0.0.1.jar(5KB)
--------commons-codec-1.4.jar(57KB)
--------ring-jetty-adapter-0.3.11.jar(2KB)
--------httpclient-4.1.1.jar(343KB)
--------json-simple-1.1.jar(16KB)
--------kryo-2.17.jar(157KB)
--------curator-client-1.0.1.jar(24KB)
--------tools.macro-0.1.0.jar(5KB)
--------jetty-6.1.26.jar(527KB)
--------clojure-1.4.0.jar(3.26MB)
--------minlog-1.2.jar(5KB)