Docker compose sandbox for Kafka MirrorMaker 2.0
-
Start containers:
docker-compose up
-
Create topic in source cluster:
docker-compose exec srcKafka1 kafka-topics \
--create \
--bootstrap-server localhost:9092 \
--replication-factor 1
- Consume messages in target cluster:
docker-compose exec kafkacat kafkacat -b destKafka1:11091 -C -t users
- Produce messages from source cluster:
docker-compose exec kafkacat kafkacat -b srcKafka1:10091 -P -t users