Skip to content

Commit f6c48f1

Browse files
committed
merging changes from public pr
1 parent e6ba743 commit f6c48f1

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

articles/hdinsight/kafka/apache-kafka-producer-consumer-api.md

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ ms.reviewer: jasonh
77
ms.service: hdinsight
88
ms.custom: hdinsightactive
99
ms.topic: tutorial
10-
ms.date: 10/08/2019
10+
ms.date: 05/19/2020
1111
#Customer intent: As a developer, I need to create an application that uses the Kafka consumer/producer API with Kafka on HDInsight
1212
---
1313

@@ -113,14 +113,12 @@ The [Run.java](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started
113113

114114
Download the jars from the [Kafka Get Started Azure sample](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started/tree/master/Prebuilt-Jars). If your cluster is **Enterprise Security Package (ESP)** enabled, use kafka-producer-consumer-esp.jar. Use the command below to copy the jars to your cluster.
115115

116-
117-
```cmd
118-
scp kafka-producer-consumer*.jar [email protected]:kafka-producer-consumer.jar
119-
```
116+
```cmd
117+
scp kafka-producer-consumer*.jar [email protected]:kafka-producer-consumer.jar
118+
```
120119

121120
## Build the JAR files from code
122121

123-
124122
If you would like to skip this step, prebuilt jars can be downloaded from the `Prebuilt-Jars` subdirectory. Download the kafka-producer-consumer.jar. If your cluster is **Enterprise Security Package (ESP)** enabled, use kafka-producer-consumer-esp.jar. Execute step 3 to copy the jar to your HDInsight cluster.
125123

126124
1. Download and extract the examples from [https://github.com/Azure-Samples/hdinsight-kafka-java-get-started](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started).
@@ -140,7 +138,6 @@ If you would like to skip this step, prebuilt jars can be downloaded from the `P
140138
```
141139
142140
## <a id="run"></a> Run the example
143-
This conversation was marked as resolved by anusricorp
144141
145142
1. Replace `sshuser` with the SSH user for your cluster, and replace `CLUSTERNAME` with the name of your cluster. Open an SSH connection to the cluster, by entering the following command. If prompted, enter the password for the SSH user account.
146143
@@ -159,6 +156,7 @@ This conversation was marked as resolved by anusricorp
159156
160157
> [!Note]
161158
> This command requires Ambari access. If your cluster is behind an NSG, run this command from a machine that can access Ambari.
159+
162160
1. Create Kafka topic, `myTest`, by entering the following command:
163161
164162
```bash

0 commit comments

Comments
 (0)