Skip to content

Commit 30e2c66

Browse files
authored
Incorporated the review comments.
Incorporated the review comments.
1 parent 3bafcf6 commit 30e2c66

File tree

1 file changed

+25
-25
lines changed

1 file changed

+25
-25
lines changed

articles/hdinsight/kafka/connect-kafka-with-vnet.md

Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ This article describes the steps to set up the connectivity between a virtual ma
3333
1. Update /etc/hosts file in client machine: Update `/etc/hosts` file in client machine with `/etc/hosts` file of Kafka Head/Worker node.
3434

3535
> [!NOTE]
36-
> 1. Private DNS setup is optional after IP advertising. This is required only when you want to use FQDN of Kafka worker nodes with private DNS domain name instead of private IPs.
37-
> 1. IPs of Kafka VMs never change if VM is present in cluster. Only when you manually replace VM from the cluster then, that IP changes. You can check the latest IPs from Ambari portal.
36+
> * Private DNS setup is optional after IP advertising. This is required only when you want to use FQDN of Kafka worker nodes with private DNS domain name instead of private IPs.
37+
> * IPs of Kafka VMs never change if VM is present in cluster. Only when you manually replace VM from the cluster then, that IP changes. You can check the latest IPs from Ambari portal.
3838
3939
### Configure Kafka for IP advertising
4040
This configuration allows the client to connect using broker IP addresses instead of domain names. By default, Apache Zookeeper returns the domain name of the Kafka brokers to clients.
@@ -175,39 +175,39 @@ Use the following steps to configure HDInsight Kafka to advertise IP addresses i
175175
</html>
176176
```
177177
178-
#### If Client VM is using Windows OS
178+
### If Client VM is using Windows OS
179179
180-
1. Go to overview page of `hdi-kafka` and click on Ambari view to get the URL.
180+
1. Go to overview page of `hdi-kafka` and click on Ambari view to get the URL.
181181
182-
1. Put the login credential as username `admin` and password `YOUR_PASSWORD`, which you have set while creating cluster.
182+
1. Put the login credential as username `admin` and password `YOUR_PASSWORD`, which you have set while creating cluster.
183183
184-
> [!NOTE]
185-
> 1. In Windows VM, static hostnames need to be added in the host file which present in the path `C:\Windows\System32\drivers\etc\`.
186-
> 1. This article assumes that the Ambari server is active on `Head Node 0`. If the Ambari server is active on `Head Node 1` use the FQDN of hn1 to access the Ambari UI.
184+
> [!NOTE]
185+
> 1. In Windows VM, static hostnames need to be added in the host file which present in the path `C:\Windows\System32\drivers\etc\`.
186+
> 1. This article assumes that the Ambari server is active on `Head Node 0`. If the Ambari server is active on `Head Node 1` use the FQDN of hn1 to access the Ambari UI.
187187
188-
:::image type="content" source="./media/connect-kafka-with-vnet/dashboard.png" alt-text="Screenshot showing the dashboard." border="true" lightbox="./media/connect-kafka-with-vnet/dashboard.png":::
188+
:::image type="content" source="./media/connect-kafka-with-vnet/dashboard.png" alt-text="Screenshot showing the dashboard." border="true" lightbox="./media/connect-kafka-with-vnet/dashboard.png":::
189189
190-
1. You can also send messages to kafka topic and read the topics from the VM. For that you can try to use this sample java application.
190+
1. You can also send messages to kafka topic and read the topics from the VM. For that you can try to use this sample java application.
191191
192-
1. Use sample git repository to create Kafka topics, produce and consume data from that topic. For more information, see [hdinsight-kafka-java-getting-started](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started).
192+
1. Use sample git repository to create Kafka topics, produce and consume data from that topic. For more information, see [hdinsight-kafka-java-getting-started](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started).
193193
194-
1. You can use FQDN, IP or short name(first six letters of cluster name) of brokers to pass as `KAFKABROKERS` in the following commands.
194+
1. You can use FQDN, IP or short name(first six letters of cluster name) of brokers to pass as `KAFKABROKERS` in the following commands.
195195
196-
```
197-
# In the previous example # IP of worker node 0 is `broker1-ip` and worker node 1 is `broker2-ip`
198-
# Short Name of worker node 0 is `wn0-hdi-ka` and worker node 1 is `wn1-hdi-ka` # FQDN of worker node 0 is `wn0-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net` and worker node 1 is `wn1-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net`
196+
```
197+
# In the previous example # IP of worker node 0 is `broker1-ip` and worker node 1 is `broker2-ip`
198+
# Short Name of worker node 0 is `wn0-hdi-ka` and worker node 1 is `wn1-hdi-ka` # FQDN of worker node 0 is `wn0-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net` and worker node 1 is `wn1-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net`
199199
200-
# Create Kafka Topic
201-
java -jar kafka-producer-consumer.jar create <topic_name> $KAFKABROKERS
202-
java -jar kafka-producer-consumer.jar create test broker1-ip:9092,broker2-ip:9092
200+
# Create Kafka Topic
201+
java -jar kafka-producer-consumer.jar create <topic_name> $KAFKABROKERS
202+
java -jar kafka-producer-consumer.jar create test broker1-ip:9092,broker2-ip:9092
203203
204-
# Produce Data in Topic
205-
java -jar kafka-producer-consumer.jar producer <topic_name> $KAFKABROKERS
206-
java -jar kafka-producer-consumer.jar producer test wn0-hdi-ka:9092,wn1-hdi-ka:9092
204+
# Produce Data in Topic
205+
java -jar kafka-producer-consumer.jar producer <topic_name> $KAFKABROKERS
206+
java -jar kafka-producer-consumer.jar producer test wn0-hdi-ka:9092,wn1-hdi-ka:9092
207207
208-
# Consume Data from Topic
209-
java -jar kafka-producer-consumer.jar consumer <topic_name> $KAFKABROKERS
210-
java -jar kafka-producer-consumer.jar consumer test wn0-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net:9092,wn1-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net:9092
211-
```
208+
# Consume Data from Topic
209+
java -jar kafka-producer-consumer.jar consumer <topic_name> $KAFKABROKERS
210+
java -jar kafka-producer-consumer.jar consumer test wn0-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net:9092,wn1-hdi-ka.mvml5coqo4xuzc1nckq1sltcxf.bx.internal.cloudapp.net:9092
211+
```
212212
> [!NOTE]
213213
> It is recommended to add all the brokers IP, FQDN or short name in $KAFKABROKERS for fault tolerance.

0 commit comments

Comments
 (0)