submit-storm-topology.sh

#!/bin/bash

# ZK_HOST="$( echo $(docker exec -it docker-kafka-storm_supervisor_1 /bin/bash -c "env | grep ZK_PORT_2181_TCP_ADDR") | awk -F'=' '{print $NF}')"
# ZK_PORT="$( echo $(docker exec -it docker-kafka-storm_supervisor_1 /bin/bash -c "env | grep ZK_PORT_2181_TCP_PORT") | awk -F'=' '{print $NF}' | sed 's/[^0-9]//g')"
# NIMBUS_HOST="$( echo $(docker exec -it docker-kafka-storm_supervisor_1 /bin/bash -c "env | grep NIMBUS_PORT_6627_TCP_ADDR") | awk -F'=' '{print $NF}')"
# NIMBUS_THRIFT_PORT="$( echo $(docker exec -it docker-kafka-storm_supervisor_1 /bin/bash -c "env | grep NIMBUS_PORT_6627_TCP_PORT") | awk -F'=' '{print $NF}' | sed 's/[^0-9]//g')"

ZK_HOST=$(docker inspect --format '{{ .NetworkSettings.IPAddress }}' docker-kafka-storm_zookeeper_1)
NIMBUS_HOST=$(docker inspect --format '{{ .NetworkSettings.IPAddress }}' docker-kafka-storm_nimbus_1)

# Only works for container ports, that are mapped/exposed on the Host
ZK_PORT=$(docker inspect --format '{{ (index (index .NetworkSettings.Ports "2181/tcp") 0).HostPort }}' docker-kafka-storm_zookeeper_1)
NIMBUS_THRIFT_PORT=$(docker inspect --format '{{ (index (index .NetworkSettings.Ports "6627/tcp") 0).HostPort }}' docker-kafka-storm_nimbus_1)

docker run -it --rm \
        -e MAINCLASS=$1 \
        -e TOPOLOGY_NAME=$2 \
        -e TOPIC=$3 \
        -e ZK_HOST=${ZK_HOST} \
        -e ZK_PORT=${ZK_PORT} \
        -e NIMBUS_HOST=${NIMBUS_HOST} \
        -e NIMBUS_THRIFT_PORT=${NIMBUS_THRIFT_PORT} \
        --name topology \
        storm-topology \
        "submit"