2.6.0.2 — Storm
| Metric | Storm 2.5.4 | Storm 2.6.0.2 | Improvement | |--------|-------------|---------------|--------------| | Avg latency (p99) | 47 ms | 38 ms | 19% | | Max throughput (no backpressure) | 85k msg/s | 102k msg/s | 20% | | Worker OOM errors (24h run) | 4 | 0 | 100% | | Kafka rebalance time | 12 sec | 5 sec | 58% |
# storm.yaml topology.worker.max.heap.size.mb: 2048.0 topology.executor.receive.buffer.size: 32768 topology.executor.send.buffer.size: 32768 topology.backpressure.wait.strategy: "sleep" nimbus.topology.validator: "org.apache.storm.topology.DefaultTopologyValidator" storm.zookeeper.connection.timeout: 30000 storm 2.6.0.2
FROM openjdk:11-jre-slim RUN wget https://archive.apache.org/dist/storm/apache-storm-2.6.0.2/apache-storm-2.6.0.2.tar.gz RUN tar -xzf apache-storm-2.6.0.2.tar.gz ENV STORM_HOME=/apache-storm-2.6.0.2 CMD ["bin/storm", "nimbus"] End of paper. | Metric | Storm 2
Author: AI Research & Engineering Team Date: April 16, 2026 Version: 1.0 Subject: Apache Storm v2.6.0.2 (maintenance release) Abstract Apache Storm is a distributed, fault-tolerant, real-time computation system. This paper examines release 2.6.0.2 , a maintenance update within the 2.6.x lineage. We detail its architectural components, key improvements over earlier versions (2.5.x and 2.6.0.1), critical bug fixes, and operational best practices. Our evaluation indicates that 2.6.0.2 prioritizes stability in Kafka integration, enhances the UI for large topologies, and improves backpressure handling under high load. This release is recommended for production environments requiring long-running, low-latency stream processing. 1. Introduction Apache Storm has been the de facto standard for real-time stream processing since its inception at Twitter. With the rise of alternative systems like Flink and Spark Streaming, Storm maintains relevance through its at-least-once and exactly-once processing semantics (via Trident), low latency (millisecond to sub-millisecond), and true stream-at-a-time model. low latency (millisecond to sub-millisecond)
# Step 1: Backup ZooKeeper state zkDump.sh /storm > storm_state_backup.json storm supervisor --stop replace binaries to 2.6.0.2 storm supervisor --start Step 3: Upgrade Nimbus (leader first in HA mode) storm nimbus --stop replace binaries storm nimbus --start Step 4: Verify version storm version > 2.6.0.2
supervisor.memory.safety.margin.mb: 512 Prevents supervisor from oversubscribing worker memory. Prometheus endpoint enabled by default on Nimbus and Supervisor ports: