mm2

Author: hifly81

README.adoc

@@ -2284,7 +2284,106 @@ scripts/tear-down-oauth.sh
 
 Example of a Mirror Maker v2 configuration Active/Active
 
-link:mirror-maker2-tests/README.md[Mirror Maker 2 tests]
+Run the example:
+
+[source,bash]
+----
+scripts/bootstrap-mm2.sh
+----
+
+A source cluster on port 9092 and a destination cluster on port 9082 will be created.
+
+Create TopicA on source cluster and TopicB on destination cluster
+
+[source,bash]
+----
+docker exec broker kafka-topics --bootstrap-server broker:9092 --create --topic TopicA --replication-factor 1 --partitions 3
+docker exec broker-destination kafka-topics --bootstrap-server broker-destination:9082 --create --topic TopicB --replication-factor 1 --partitions 3
+----
+
+Launch Mirror Maker, both direction:
+
+[source,bash]
+----
+docker exec broker-destination bash -c 'export KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:/etc/kafka/connect-log4j.properties && connect-mirror-maker /tmp/mm2.properties'
+----
+
+Topic list on source cluster:
+
+[source,bash]
+----
+docker exec broker kafka-topics --bootstrap-server broker:9092 --list
+
+DC-Y.TopicB
+DC-Y.checkpoints.internal
+TopicA
+__consumer_offsets
+heartbeats
+mm2-configs.DC-Y.internal
+mm2-offsets.DC-Y.internal
+mm2-status.DC-Y.internal
+----
+
+Topic list on destination cluster:
+
+[source,bash]
+----
+docker exec broker-destination kafka-topics --bootstrap-server broker-destination:9082 --list
+
+DC-X.TopicA
+DC-X.checkpoints.internal
+TopicB
+__consumer_offsets
+heartbeats
+mm2-configs.DC-X.internal
+mm2-offsets.DC-X.internal
+mm2-status.DC-X.internal
+----
+
+Run Producer Perf Test on cluster source for TopicA:
+
+[source,bash]
+----
+docker exec broker kafka-producer-perf-test --topic TopicA --num-records 10000 --record-size 100 --throughput -1 --producer-props acks=1 bootstrap.servers=broker:9092 buffer.memory=67108864 batch.size=8196
+----
+
+Run Producer Perf Test on cluster destination for TopicB:
+
+[source,bash]
+----
+docker exec broker-destination kafka-producer-perf-test --topic TopicB --num-records 10000 --record-size 100 --throughput -1 --producer-props acks=1 bootstrap.servers=broker-destination:9082 buffer.memory=67108864 batch.size=8196
+----
+
+Verify Topic message size for TopicA (cluster 1) and for DCX.TopicA (cluster2):
+
+[source,bash]
+----
+docker exec broker ls -ltr /tmp/kraft-combined-logs/TopicA-0
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/DC-X.TopicA-0
+docker exec broker ls -ltr /tmp/kraft-combined-logs/TopicA-1
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/DC-X.TopicA-1
+docker exec broker ls -ltr /tmp/kraft-combined-logs/TopicA-2
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/DC-X.TopicA-2
+----
+
+Verify Topic message size for TopicB (cluster 2) and for DCY.TopicB (cluster1):
+
+[source,bash]
+----
+docker exec broker ls -ltr /tmp/kraft-combined-logs/DC-Y.TopicB-0
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/TopicB-0
+docker exec broker ls -ltr /tmp/kraft-combined-logs/DC-Y.TopicB-1
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/TopicB-1
+docker exec broker ls -ltr /tmp/kraft-combined-logs/DC-Y.TopicB-2
+docker exec broker-destination ls -ltr /tmp/kraft-combined-logs/TopicB-2
+----
+
+Teardown:
+
+[source,bash]
+----
+scripts/tear-down-mm2.sh
+----
 
 == Observability