1.0.6
,1.0
(1.0.6/Dockerfile)1.1.3
,1.1
, (1.1.3/Dockerfile)1.2.2
,1.2
,latest
(1.2.2/Dockerfile)
Apache Storm is a distributed computation framework written predominantly in the Clojure programming language. Originally created by Nathan Marz and team at BackType, the project was open sourced after being acquired by Twitter. It uses custom created "spouts" and "bolts" to define information sources and manipulations to allow batch, distributed processing of streaming data. The initial release was on 17 September 2011.
Assuming you have topology.jar
in the current directory.
$ docker run -it -v $(pwd)/topology.jar:/topology.jar 31z4/storm storm jar /topology.jar org.apache.storm.starter.ExclamationTopology
-
Apache Zookeeper is a must for running a Storm cluster. Start it first. Since the Zookeeper "fails fast" it's better to always restart it.
$ docker run -d --restart always --name some-zookeeper zookeeper
-
The Nimbus daemon has to be connected with the Zookeeper. It's also a "fail fast" system.
$ docker run -d --restart always --name some-nimbus --link some-zookeeper:zookeeper 31z4/storm storm nimbus
-
Finally start a single Supervisor node. It will talk to the Nimbus and Zookeeper.
$ docker run -d --restart always --name supervisor --link some-zookeeper:zookeeper --link some-nimbus:nimbus 31z4/storm storm supervisor
-
Now you can submit a topology to our cluster.
$ docker run --link some-nimbus:nimbus -it --rm -v $(pwd)/topology.jar:/topology.jar 31z4/storm storm jar /topology.jar org.apache.storm.starter.WordCountTopology topology
-
Optionally, you can start the Storm UI.
$ docker run -d -p 8080:8080 --restart always --name ui --link some-nimbus:nimbus 31z4/storm storm ui
... via docker stack deploy
or docker-compose
Example stack.yml
for 31z4/storm
:
version: '3.1'
services:
zookeeper:
image: zookeeper
container_name: zookeeper
restart: always
nimbus:
image: 31z4/storm
container_name: nimbus
command: storm nimbus
depends_on:
- zookeeper
links:
- zookeeper
restart: always
ports:
- 6627:6627
supervisor:
image: 31z4/storm
container_name: supervisor
command: storm supervisor
depends_on:
- nimbus
- zookeeper
links:
- nimbus
- zookeeper
restart: always
Run docker stack deploy -c stack.yml storm
(or docker-compose -f stack.yml up
) and wait for it to initialize completely. The Nimbus will be available at http://swarm-ip:6627
, http://localhost:6627
, or http://host-ip:6627
(as appropriate).
This image uses default configuration of the Apache Storm. There are two main ways to change it.
-
Using command line arguments.
$ docker run -d --restart always --name nimbus 31z4/storm storm nimbus -c storm.zookeeper.servers='["zookeeper"]'
-
Assuming you have
storm.yaml
in the current directory you can mount it as a volume.$ docker run -it -v $(pwd)/storm.yaml:/conf/storm.yaml 31z4/storm storm nimbus
This image uses default logging configuration. All logs go to the /logs
directory by default.
No data are persisted by default. For convenience there are /data
and /logs
directories in the image owned by storm
user. Use them accordingly to persist data and logs using volumes.
$ docker run -it -v /logs -v /data 31z4/storm storm nimbus
Please be noticed that using paths other than those predefined is likely to cause permission denied errors. It's because for security reasons the Storm is running under the non-root storm
user.
View license information for the software contained in this image.