Skip to content

Commit 86c3085

Browse files
committed
freshness30
1 parent 3d45b20 commit 86c3085

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

articles/hdinsight/kafka/apache-kafka-streams-api.md

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@ author: hrasheed-msft
55
ms.author: hrasheed
66
ms.reviewer: jasonh
77
ms.service: hdinsight
8-
ms.custom: hdinsightactive
98
ms.topic: tutorial
10-
ms.date: 10/08/2019
9+
ms.custom: hdinsightactive
10+
ms.date: 03/20/2020
1111
#Customer intent: As a developer, I need to create an application that uses the Kafka streams API with Kafka on HDInsight
1212
---
1313

@@ -68,7 +68,7 @@ The important things to understand in the `pom.xml` file are:
6868
* Plugins: Maven plugins provide various capabilities. In this project, the following plugins are used:
6969

7070
* `maven-compiler-plugin`: Used to set the Java version used by the project to 8. Java 8 is required by HDInsight 3.6.
71-
* `maven-shade-plugin`: Used to generate an uber jar that contains this application as well as any dependencies. It's also used to set the entry point of the application, so that you can directly run the Jar file without having to specify the main class.
71+
* `maven-shade-plugin`: Used to generate an uber jar that contains this application, and any dependencies. It's also used to set the entry point of the application, so that you can directly run the Jar file without having to specify the main class.
7272

7373
### Stream.java
7474

@@ -162,23 +162,24 @@ To build and deploy the project to your Kafka on HDInsight cluster, use the foll
162162
```
163163
164164
4. Extract correctly cased cluster name. The actual casing of the cluster name may be different than you expect, depending on how the cluster was created. This command will obtain the actual casing, and then store it in a variable. Enter the following command:
165+
165166
```bash
166167
export clusterName=$(curl -u admin:$password -sS -G "http://headnodehost:8080/api/v1/clusters" | jq -r '.items[].Clusters.cluster_name')
167168
```
168169
169170
> [!Note]
170171
> If you're doing this process from outside the cluster, there is a different procedure for storing the cluster name. Get the cluster name in lower case from the Azure portal. Then, substitute the cluster name for `<clustername>` in the following command and execute it: `export clusterName='<clustername>'`.
171172
172-
5. To get the Kafka broker hosts and the Apache Zookeeper hosts, use the following commands. When prompted, enter the password for the cluster login (admin) account. You are prompted for the password twice.
173+
5. To get the Kafka broker hosts and the Apache Zookeeper hosts, use the following commands. When prompted, enter the password for the cluster login (admin) account.
173174
174175
```bash
175176
export KAFKAZKHOSTS=$(curl -sS -u admin:$password -G https://$clusterName.azurehdinsight.net/api/v1/clusters/$clusterName/services/ZOOKEEPER/components/ZOOKEEPER_SERVER | jq -r '["\(.host_components[].HostRoles.host_name):2181"] | join(",")' | cut -d',' -f1,2);
176177
177178
export KAFKABROKERS=$(curl -sS -u admin:$password -G https://$clusterName.azurehdinsight.net/api/v1/clusters/$clusterName/services/KAFKA/components/KAFKA_BROKER | jq -r '["\(.host_components[].HostRoles.host_name):9092"] | join(",")' | cut -d',' -f1,2);
178179
```
179180
180-
> [!Note]
181-
> These commands require Ambari access. If your cluster is behind an NSG, run these commands from a machine that can access Ambari.
181+
> [!Note]
182+
> These commands require Ambari access. If your cluster is behind an NSG, run these commands from a machine that can access Ambari.
182183
183184
6. To create the topics used by the streaming operation, use the following commands:
184185

0 commit comments

Comments
 (0)