Skip to content

Commit 7a3bdb0

Browse files
authored
Merge pull request #99572 from poulinjulien/patch-1
Fix a few indentation/spacing issues
2 parents af85e7f + 41f020f commit 7a3bdb0

File tree

1 file changed

+31
-31
lines changed

1 file changed

+31
-31
lines changed

articles/hdinsight/kafka/kafka-mirrormaker-2-0-guide.md

Lines changed: 31 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,8 @@ The summary of the broker setup process is as follows:
4242

4343
**MirrorCheckpointConnector:**
4444

45-
1. Consumes offset-syncsr.
46-
1. Emits checkpoints to enable failover points.
45+
1. Consumes offset-syncsr.
46+
1. Emits checkpoints to enable failover points.
4747

4848
**MirrorHeartBeatConnector:**
4949

@@ -53,47 +53,48 @@ The summary of the broker setup process is as follows:
5353

5454
1. Connect-mirror-maker.sh script bundled with the Kafka library implements a distributed MM2 cluster, which manages the Connect workers internally based on a config file. Internally MirrorMaker driver creates and handles pairs of each connector – MirrorSourceConnector, MirrorSinkConnector, MirrorCheckpoint connector and MirrorHeartbeatConnector.
5555
1. Start MirrorMaker 2.0.
56-
57-
```
58-
./bin/connect-mirror-maker.sh ./config/mirror-maker.properties
59-
```
56+
57+
```
58+
./bin/connect-mirror-maker.sh ./config/mirror-maker.properties
59+
```
6060

6161
> [!NOTE]
6262
> For Kerberos enabled clusters, the JAAS configuration must be exported to the KAFKA_OPTS or must be specified in the MM2 config file.
6363
6464
```
6565
export KAFKA_OPTS="-Djava.security.auth.login.config=<path-to-jaas.conf>"
6666
```
67+
6768
### Sample MirrorMaker 2.0 Configuration file
6869
6970
```
70-
# specify any number of cluster aliases
71-
clusters = source, destination
71+
# specify any number of cluster aliases
72+
clusters = source, destination
7273
73-
# connection information for each cluster
74-
# This is a comma separated host:port pairs for each cluster
75-
# for example. "A_host1:9092, A_host2:9092, A_host3:9092" and you can see the exact host name on Ambari > Hosts
76-
source.bootstrap.servers = wn0-src-kafka.bx.internal.cloudapp.net:9092,wn1-src-kafka.bx.internal.cloudapp.net:9092,wn2-src-kafka.bx.internal.cloudapp.net:9092
77-
destination.bootstrap.servers = wn0-dest-kafka.bx.internal.cloudapp.net:9092,wn1-dest-kafka.bx.internal.cloudapp.net:9092,wn2-dest-kafka.bx.internal.cloudapp.net:9092
74+
# connection information for each cluster
75+
# This is a comma separated host:port pairs for each cluster
76+
# for example. "A_host1:9092, A_host2:9092, A_host3:9092" and you can see the exact host name on Ambari > Hosts
77+
source.bootstrap.servers = wn0-src-kafka.bx.internal.cloudapp.net:9092,wn1-src-kafka.bx.internal.cloudapp.net:9092,wn2-src-kafka.bx.internal.cloudapp.net:9092
78+
destination.bootstrap.servers = wn0-dest-kafka.bx.internal.cloudapp.net:9092,wn1-dest-kafka.bx.internal.cloudapp.net:9092,wn2-dest-kafka.bx.internal.cloudapp.net:9092
7879
79-
# enable and configure individual replication flows
80-
source->destination.enabled = true
80+
# enable and configure individual replication flows
81+
source->destination.enabled = true
8182
82-
# regex which defines which topics gets replicated. For eg "foo-.*"
83-
source->destination.topics = toa.evehicles-latest-dev
84-
groups=.*
85-
topics.blacklist="*.internal,__.*"
83+
# regex which defines which topics gets replicated. For eg "foo-.*"
84+
source->destination.topics = toa.evehicles-latest-dev
85+
groups=.*
86+
topics.blacklist="*.internal,__.*"
8687
87-
# Setting replication factor of newly created remote topics
88-
replication.factor=3
88+
# Setting replication factor of newly created remote topics
89+
replication.factor=3
8990
90-
checkpoints.topic.replication.factor=1
91-
heartbeats.topic.replication.factor=1
92-
offset-syncs.topic.replication.factor=1
91+
checkpoints.topic.replication.factor=1
92+
heartbeats.topic.replication.factor=1
93+
offset-syncs.topic.replication.factor=1
9394
94-
offset.storage.replication.factor=1
95-
status.storage.replication.factor=1
96-
config.storage.replication.factor=1
95+
offset.storage.replication.factor=1
96+
status.storage.replication.factor=1
97+
config.storage.replication.factor=1
9798
```
9899

99100
### SSL configuration
@@ -109,7 +110,6 @@ destination.ssl.keystore.location=/path/to/kafka.server.keystore.jks
109110
destination.sasl.mechanism=GSSAPI
110111
```
111112

112-
113113
### Global configurations
114114

115115
|Property |Default value |Description |
@@ -167,9 +167,9 @@ destination.sasl.mechanism=GSSAPI
167167
Custom Replication Policy can be created by implementing the interface below.
168168

169169
```
170-
/** Defines which topics are "remote topics", e.g. "us-west.topic1". */
171-
public interface ReplicationPolicy {
172-
170+
/** Defines which topics are "remote topics", e.g. "us-west.topic1". */
171+
public interface ReplicationPolicy {
172+
173173
/** How to rename remote topics; generally should be like us-west.topic1. */
174174
String formatRemoteTopic(String sourceClusterAlias, String topic);
175175

0 commit comments

Comments
 (0)