Storm 2.6.0.2 May 2026

I have provided a LinkedIn/Professional version and a Twitter/X version.

2.1. Core Engine Improvements

• Backpressure mechanism overhaul: More responsive handling of slow consumers, reducing cascading failures in topologies with high throughput.
• Improved windowing performance: Reduced memory footprint for sliding/tumbling windows, especially under late-arriving data.
• Faster rebalancing: ZooKeeper-based coordination optimizations cut topology rebalance time by ~30% in large clusters.

Metrics - stable Prometheus reporter

storm.metrics.reporters:

• class: "org.apache.storm.metrics.prometheus.PrometheusMetricsReporter" port: 8001

4. Performance Optimizations

• Faster message passing via Netty improvements.
• Reduced memory footprint for large topologies when using WindowedBolt.

2.4. Observability

• Micrometer metrics integration: Native export of Storm metrics to Prometheus, Datadog, or Graphite.
• Structured logging: JSON log format option for easier ingestion into ELK/Splunk.
• UI improvements: Topology visualization now shows per-operator backpressure state and lag histograms.

3. Upgrade Considerations (from 2.5.x or earlier)

| Area | Action Required | |------|----------------| | ZooKeeper | No version bump needed, but ensure storm.zookeeper.session.timeout is at least 30s. | | Serialization | Kryo version remains compatible; no code changes expected. | | Topology submission | storm jar behavior unchanged, but new --dynamic flag for experimental scaling. | | Metrics | Old graphite reporter deprecated; migrate to micrometer configuration. |

Upgrade Path

• From 2.5.x → 2.6.0.2: Rolling upgrade supported (backward compatible topology serialization).
• From 2.6.0 → 2.6.0.2: Hot-patch safe (only JAR updates, no metadata changes).