File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
articles/hdinsight/domain-joined Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -199,13 +199,13 @@ To produce and consume topics in ESP Kafka by using the console:
199
199
3 . Produce messages to topic ` salesevents ` :
200
200
201
201
``` bash
202
- /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --topic salesevents --broker-list $KAFKABROKERS --security-protocol SASL_PLAINTEXT
202
+ /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --topic salesevents --broker-list $KAFKABROKERS --producer-property security.protocol= SASL_PLAINTEXT
203
203
```
204
204
205
205
4 . Consume messages from topic ` salesevents ` :
206
206
207
207
``` bash
208
- /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --topic salesevents --from-beginning --bootstrap-server $KAFKABROKERS --security-protocol SASL_PLAINTEXT
208
+ /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --topic salesevents --from-beginning --bootstrap-server $KAFKABROKERS --consumer-property security.protocol= SASL_PLAINTEXT
209
209
```
210
210
211
211
## Produce and consume topics for long running session in ESP Kafka
@@ -238,8 +238,8 @@ To use keytab in long running session without `kinit`:
238
238
239
239
# console tool
240
240
export KAFKA_OPTS="-Djava.security.auth.login.config=/home/sshuser/kafka_client_jaas.conf"
241
- /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --topic salesevents --broker-list $KAFKABROKERS --security-protocol SASL_PLAINTEXT
242
- /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --topic salesevents --from-beginning --bootstrap-server $KAFKABROKERS --security-protocol SASL_PLAINTEXT
241
+ /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --topic salesevents --broker-list $KAFKABROKERS --producer-property security.protocol= SASL_PLAINTEXT
242
+ /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --topic salesevents --from-beginning --bootstrap-server $KAFKABROKERS --consumer-property security.protocol= SASL_PLAINTEXT
243
243
244
244
# API
245
245
java -jar -Djava.security.auth.login.config=/home/sshuser/kafka_client_jaas.conf kafka-producer-consumer.jar producer salesevents $KAFKABROKERS
You can’t perform that action at this time.
0 commit comments