Skip to content

Commit d0358a8

Browse files
authored
Improved Acrolinx Score
Improved Acrolinx Score
1 parent 3868470 commit d0358a8

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

articles/hdinsight/kafka/apache-kafka-mirror-maker-2.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ description: Learn how to use MirrorMaker 2 to migrate Kafka clusters between di
44
ms.service: hdinsight
55
ms.topic: how-to
66
ms.custom: hdinsightactive
7-
ms.date: 04/20/2023
7+
ms.date: 04/25/2023
88
---
99

1010
# Use MirrorMaker 2 to migrate Kafka clusters between different Azure HDInsight versions
@@ -103,7 +103,7 @@ This architecture features two clusters in different resource groups and virtual
103103
```
104104
1. Edit the `/etc/hosts` file of secondary cluster and add those entries here.
105105

106-
1. After making the changes, the `/etc/hosts` file for `SECONDARYCLUSTER` looks like the given image.
106+
1. After you making the changes, the `/etc/hosts` file for `SECONDARYCLUSTER` looks like the given image.
107107

108108
:::image type="content" source="./media/apache-kafka-mirror-maker2/ect-host.png" lightbox="./media/apache-kafka-mirror-maker2/ect-host.png" alt-text="Screenshot that shows etc hosts file output." border="false":::
109109

@@ -157,7 +157,7 @@ This architecture features two clusters in different resource groups and virtual
157157
```
158158

159159
1. Here source is your `PRIMARYCLUSTER` and destination is your `SECONDARYCLUSTR`. Replace it everywhere with correct name and replace `source.bootstrap.servers` and `destination.bootstrap.servers` with correct FQDN or IP of their respective worker nodes.
160-
1. You can use regular expressions to specify the topics and their configurations that you want to replicate. By setting the `replication.factor` parameter to 3, you can ensure that all topics created by the MirrorMaker script will have a replication factor of 3.
160+
1. You can use regular expressions to specify the topics and their configurations that you want to replicate. By setting the `replication.factor` parameter to 3, you can ensure that all topics created by the MirrorMaker script hsd a replication factor of 3.
161161
1. Increase the replication factor from 1 to 3 for these topics
162162
```
163163
checkpoints.topic.replication.factor=1
@@ -177,7 +177,7 @@ This architecture features two clusters in different resource groups and virtual
177177
destination->source.enabled=true
178178
destination->source.topics = .*
179179
```
180-
1. For automated consumer offset sync, we need to enable replication and control the sync duration too. Below property will sync offset every 30 second. For active-active scenario we need to do it both ways
180+
1. For automated consumer offset sync, we need to enable replication and control the sync duration too. Following property syncs offset every 30 second. For active-active scenario, we need to do it both ways.
181181
```
182182
groups=.*
183183
@@ -276,13 +276,13 @@ This architecture features two clusters in different resource groups and virtual
276276
277277
export KAFKAZKHOSTS='zk0-second:2181'
278278
279-
# List all the topics whether they are replicated or not
279+
# List all the topics whether they're replicated or not
280280
bash /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --list
281281
282282
# Start Consumer
283283
bash /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server $KAFKABROKERS --topic $TOPICNAME --from-beginning
284284
```
285-
You will notice that in secondary cluster consumer group my-group will not consume any messages because they are already consumed by primary cluster consumer group. Now produce more messages in primary-cluster and try to consumer then in secondary-cluster. You will be able to consume from secondarycluster.
285+
You can notice that in secondary cluster consumer group my-group cant't consume any messages because, already consumed by primary cluster consumer group. Now produce more messages in primary-cluster and try to consumer then in secondary-cluster. You are able to consume from `SECONDARYCLUSTER`.
286286

287287
## Delete cluster
288288

0 commit comments

Comments
 (0)