Learning kafka using Go and library shopify sarama
- Using wordlist
word.txt
for dummy publish message
-
Setup docker container
bash run-docker.sh
-
Setup topic name
export KAFKA_TOPIC="kafka-topic"
-
Setup broker & zookeeper connection
export KAFKA_BROKER_URL="kafka:9092" export ZOOKEEPER_URL="zookeeper:2081"
-
Setup hosts
vi /etc/hosts ---- 127.0.0.1 zeroc0d3_kafka # container_name
-
Install Dependencies
make setup
-
Build Producer
make build-producer
-
Build Consumer
make build-consumer
-
Run Producer
make run-producer
-
Run Consumer
make run-consumer
- Author : Dwi Fahni Denni (@zeroc0d3)
- License: Apache ver-2