- git clone https://github.com/wurstmeister/kafka-docker.git
- Edit the docker-compose.yml to provide KAFKA_ADVERTISED_HOST_NAME and KAFKA_ZOOKEEPER_CONNECT host ips. This is the IP of the host on which we are going to run the docker containers for Kafka and Zookeeper.
- Start a cluster in detached mode:
docker-compose up -d
It will start 2 containers: kafkadocker_kafka_1 - with kafka running at 9092 mapped to 9092 of localhost kafkadocker_zookeeper_1 - with zookeeper running at 2181 mapped to 2181 of localhost To start a cluster with 2 brokers:
docker-compose scale kafka=2
You can use docker-compose ps to show the running instances. If you want to add more Kafka brokers simply increase the value passed to docker-compose scale kafka=n If you want to customise any Kafka parameters, simply add them as environment variables in docker-compose.yml. For example:
- to increase the message.max.bytes parameter add KAFKA_MESSAGE_MAX_BYTES: 2000000 to the environment section.
- to turn off automatic topic creation set KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'
To interact with Kafka container use the kafka-shell as: $ start-kafka-shell.sh
To test your setup, start a shell, create a topic and start a producer:
$ $KAFKA_HOME/bin/kafka-topics.sh --describe --topic "topic" --zookeeper $ZK
$ $KAFKA_HOME/bin/kafka-console-producer.sh --topic="topic" \
Start another shell and start consumer:
$ $KAFKA_HOME/bin/kafka-console-consumer.sh --topic=topic --zookeeper=$ZK
Type in producer shell and it should be published to the client's shell.