Skip to content

Commit 8631cbb

Browse files
authored
Modified the alignments for some code blocks
Modified the alignments for some code blocks
1 parent 395e707 commit 8631cbb

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

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

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -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 control the topics that you want to replicate along with configurations using regular expressions. `replication.factor=3` makes the replication factor = 3 for all the topic which Mirror maker script creates by itself.
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.
161161
1. Increase the replication factor from 1 to 3 for these topics
162162
```
163163
checkpoints.topic.replication.factor=1
@@ -218,9 +218,9 @@ This architecture features two clusters in different resource groups and virtual
218218
groups=.*
219219
emit.checkpoints.enabled = true
220220
primary-kafka-cluster->secondary-kafka-cluster.sync.group.offsets.enabled=true
221-
primary-kafka-cluster->secondary-kafka- cluster.sync.group.offsets.interval.ms=30000
221+
primary-kafka-cluster->secondary-kafka-cluster.sync.group.offsets.interval.ms=30000
222222
secondary-kafka-cluster->primary-kafka-cluster.sync.group.offsets.enabled = true
223-
secondary-kafka-cluster->primary-kafka- cluster.sync.group.offsets.interval.ms=30000
223+
secondary-kafka-cluster->primary-kafka-cluster.sync.group.offsets.interval.ms=30000
224224
topics.blacklist="*.internal,__.*"
225225
226226
# Setting replication factor of newly created remote topics
@@ -250,19 +250,21 @@ This architecture features two clusters in different resource groups and virtual
250250
export KAFKAZKHOSTS='zk0-primar:2181'
251251
252252
//Start Producer
253-
For Kafka 2.4
253+
254+
# For Kafka 2.4
254255
bash /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --zookeeper $KAFKAZKHOSTS --topic $TOPICNAME
255-
For Kafka 3.2
256-
bash /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list $KAFKABROKERS --topic $TOPICNAME
256+
# For Kafka 3.2
257+
bash /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --boostrap-server $KAFKABROKERS --topic $TOPICNAME
257258
```
258259
1. Now start the consumer in PRIMARYCLUSTER with a consumer group
259260
```
260-
//Start Consumer
261-
For Kafka 2.4
261+
//Start Consumer
262+
263+
# For Kafka 2.4
262264
bash /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --zookeeper $KAFKAZKHOSTS --topic $TOPICNAME -–group my-group –-from- beginning
263265
264-
For Kafka 3.2
265-
bash /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list $KAFKABROKERS --topic $TOPICNAME -–group my-group –-from-beginning
266+
# For Kafka 3.2
267+
bash /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --boostrap-server $KAFKABROKERS --topic $TOPICNAME -–group my-group –-from-beginning
266268
```
267269
1. Now stop the consumer in PRIMARYCONSUMER and start consumer in SECONDARYCLUSTER with same consumer group
268270
```

0 commit comments

Comments
 (0)