Test Apache Kafka

test kafka.sh

# Start Kafka locally on Docker

mkdir kafka
cd kafka
curl -sSL https://raw.githubusercontent.com/bitnami/bitnami-docker-kafka/master/docker-compose.yml > docker-compose.yml
docker-compose up -d

# Connect to docker

docker ps
docker exec -it {containerId} sh
cd /opt/bitnami/kafka/bin

# Configure topics

./kafka-topics.sh --bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic test

# Consume from topic

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

# Produce to topic

./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test