Skip to content

Latest commit

 

History

History
23 lines (19 loc) · 546 Bytes

README.md

File metadata and controls

23 lines (19 loc) · 546 Bytes
Raw

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