#!/bin/bash

DIR=$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )

IP=$(docker-machine ip)
for i in {1..3}; do
  docker rm -f kafka${i} 2>/dev/null; docker run --name kafka${i} -d --env-file=$DIR/env \
    -p ${i}9092:9092 -p ${i}7203:7203 \
    -e KAFKA_BROKER_ID=${i} -e SERVICE_9092_ID=kafka-clients-${i} \
    -e CONSUL_HOST=${IP} \
    -e KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote.rmi.port=${i}7203 -Djava.rmi.server.hostname=${IP}" \
    c3dev/kafka
done
