Apache Storm是一個免費(fèi)開源的分布式實(shí)時計(jì)算系統(tǒng)。簡化了流數(shù)據(jù)的可靠處理，像Hadoop一樣實(shí)現(xiàn)實(shí)時處理。Storm很簡單，可用于任意編程語言。Apache Storm 采用Clojure 開發(fā)。

Storm 有很多應(yīng)用場景，包括實(shí)時數(shù)據(jù)分析、聯(lián)機(jī)學(xué)習(xí)、持續(xù)計(jì)算、分布式 RPC、ETL 等。Storm 速度非?？?，一個測試在單節(jié)點(diǎn)上實(shí)現(xiàn)每秒一百萬的組處理。

1.1.1版已經(jīng)發(fā)布，這是一個維護(hù)版本，其中包含一些重要的bug修復(fù)，可以提高Storm的性能、穩(wěn)定性和容錯性。我們鼓勵以前版本的用戶升級到最新版本。托管在Maven Central。

Storm是一個事件處理程序，可以對流數(shù)據(jù)進(jìn)行分布式處理。一個Storm應(yīng)用程序由“spouts”和“bolts”構(gòu)成，它們被配置成一個有向無環(huán)圖，用來表示信息源和數(shù)據(jù)處理程序。Storm的主要特點(diǎn)是能處理實(shí)時數(shù)據(jù)，不像Hadoop那樣允許批處理。

Full Changelog
STORM-2659: Add daemon.name variable to storm.cmd to fix log4j logging
STORM-2652: fix error in open method of JmsSpout
STORM-2645: Update storm.py to be python3 compatible
STORM-2621: add tuple_population metric
STORM-2639: Kafka Spout incorrectly computes numCommittedOffsets due to voids in the topic (topic compaction)
STORM-2544: Fixing issue in acking of tuples that hit retry limit under manual commit mode
STORM-2618: Add TridentKafkaStateUpdater for storm-kafka-client
STORM-2608: Remove any pending offsets that are no longer valid
STORM-2503: Fix lgtm.com alerts on equality and comparison operations
STORM-2478: Fix BlobStoreTest.testDeleteAfterFailedCreate on Windows
STORM-2602: storm.zookeeper.topology.auth.payload doesn't work even you set it
STORM-2597: Don't parse passed in class paths
STORM-2564: We should provide a template for storm-cluster-auth.yaml
STORM-2568: Fix getTopicsString
STORM-2563: Remove the workaround to handle missing UGI.loginUserFromSubject
STORM-2552: KafkaSpoutMessageId should be serializable
STORM-2562: Use stronger key size than default for blow fish key generator and get rid of stack trace
STORM-2557: A bug in DisruptorQueue causing severe underestimation of queue arrival rates
STORM-2449: Ensure same key appears only once in State iterator
STORM-2516: Fix timing issues with testPrepareLateTupleStreamWithoutBuilder
STORM-2489: Overlap and data loss on WindowedBolt based on Duration
STORM-2528: Bump log4j version to 2.8.2
STORM-2527: Initialize java.sql.DriverManager earlier to avoid deadlock
STORM-2413: Make new Kafka spout respect tuple retry limits
STORM-2518: Handles empty name for "USER type" ACL when normalizing ACLs
STORM-2511: Submitting a topology with name containing unicode getting failed
STORM-2496: Dependency artifacts should be uploaded to blobstore with READ permission for all
STORM-2505: Spout to support topic compaction
STORM-2498: Fix Download Full File link
STORM-2343: New Kafka spout can stop emitting tuples if more than maxUncommittedOffsets tuples fail at once.
STORM-2486: Prevent cd from printing target directory to avoid breaking classpath
STORM-2488: The UI user Must be HTTP.
STORM-2481: Upgrade Aether version to resolve Aether bug BUG-451566
STORM-2435: Logging in storm.js inconsistent to console.log and does not support log levels
STORM-2315: New kafka spout can't commit offset when ack is disabled
STORM-2467: Use explicit charset when decoding from array backed buffer
STORM-1114: Race condition in trident zookeeper zk-node create/delete
STORM-2448: Add in Storm and JDK versions when submitting a topology
STORM-2343: Fix new Kafka spout stopping processing if more than maxUncommittedOffsets tuples fail at once
STORM-2431: the default blobstore.dir is storm.local.dir/blobs which is different from distcache-blobstore.md
STORM-2429: Properly validate supervisor.scheduler.meta
STORM-2451: windows storm.cmd does not set log4j2 config file correctly by default
STORM-2450: Write resources into correct local director
STORM-2440: Kill process if executor catches java.net.SocketTimeoutException
STORM-2432: Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With UNCOMMITTED_LATEST Strategy