@@ -158,9 +158,9 @@ Based on the Ranger policies configured, **sales_user** can produce/consume topi
158
158
159
159
Example: ` export KAFKAZKHOSTS=zk1-khdicl.contoso.com:2181,zk2-khdicl.contoso.com:2181 `
160
160
161
- As a result, ** sales_user1** can produce to topic ** salesevents** .
162
-
163
- 4 . Execute the following command to start the console-producer for topic ** salesevents** :
161
+ 4 . Verify that ** sales_user1** can produce to topic ** salesevents** .
162
+
163
+ Execute the following command to start the console-producer for topic ** salesevents** :
164
164
165
165
``` bash
166
166
/usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list $KAFKABROKERS --topic salesevents --security-protocol SASL_PLAINTEXT
@@ -174,19 +174,21 @@ Based on the Ranger policies configured, **sales_user** can produce/consume topi
174
174
/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --zookeeper $KAFKAZKHOSTS --topic salesevents --security-protocol PLAINTEXTSASL --from-beginning
175
175
```
176
176
177
- To verify, the messages you entered in the previous step will appear, and ** sales_user1** can't produce to topic ** marketingspend** .
177
+ 6 . Verify that the messages you entered in the previous step will appear, and ** sales_user1** can't produce to topic ** marketingspend** .
178
178
179
- 6 . From the same ssh window as above, execute the following command to produce to the topic ** marketingspend** :
179
+ From the same ssh window as above, execute the following command to produce to the topic ** marketingspend** :
180
180
181
181
``` bash
182
182
/usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list $KAFKABROKERS --topic marketingspend --security-protocol SASL_PLAINTEXT
183
183
```
184
184
185
- An authorization error occurs and can be ignored. Notice that ** marketing_user1** can't consume from topic ** salesevents** .
185
+ An authorization error occurs and can be ignored.
186
+
187
+ 7 . Notice that ** marketing_user1** can't consume from topic ** salesevents** .
186
188
187
189
Repeat steps 1-3 above, but this time as ** marketing_user1** .
188
190
189
- 7 . Execute the following command to consume from topic ** salesevents** :
191
+ Execute the following command to consume from topic ** salesevents** :
190
192
191
193
``` bash
192
194
/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --zookeeper $KAFKAZKHOSTS --topic marketingspend --security-protocol PLAINTEXTSASL --from-beginning
0 commit comments