Skip to content

Commit 1b8a645

Browse files
committed
devops3b
1 parent f1083e1 commit 1b8a645

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -148,11 +148,10 @@ The [Run.java](https://github.com/Azure-Samples/hdinsight-kafka-java-get-started
148148
export password='PASSWORD'
149149
```
150150
151-
1. To get the Kafka broker hosts and the Apache Zookeeper hosts, use the following command:
151+
1. To get the Kafka broker hosts, use the following command:
152152
153153
```bash
154-
export KAFKABROKERS=`curl -sS -u admin:$password -G https://$clusterName.azurehdinsight.net/api/v1/clusters/$clusterName/services/KAFKA/components/KAFKA_BROKER \
155-
| jq -r '["\(.host_components[].HostRoles.host_name):9092"] | join(",")' | cut -d',' -f1,2`
154+
export KAFKABROKERS=`curl -sS -u admin:$password -G http://headnodehost:8080/api/v1/clusters/$clusterName/services/KAFKA/components/KAFKA_BROKER | jq -r '["\(.host_components[].HostRoles.host_name):9092"] | join(",")' | cut -d',' -f1,2`
156155
```
157156
158157
1. Create Kafka topic, `myTest`, by entering the following command:

0 commit comments

Comments
 (0)