/kafka_mirror_maker_2_poc

Docker compose playground for Kafka MirrorMaker 2.0

Primary LanguageShell

Proof of Concept for MirrorMaker 2.0

Docker compose sandbox for Kafka MirrorMaker 2.0

  1. Start containers: docker-compose up

  2. Create topic in source cluster:

docker-compose exec srcKafka1 kafka-topics \
  --create \
  --bootstrap-server localhost:9092 \  
  --replication-factor 1
  1. Consume messages in target cluster:
docker-compose exec kafkacat kafkacat -b destKafka1:11091 -C -t users
  1. Produce messages from source cluster:
docker-compose exec kafkacat kafkacat -b srcKafka1:10091 -P -t users