Fix for HDI Kafka

algattik · algattik · commit fba6b47ca407 · 2021-01-05T14:33:58.000+01:00
diff --git a/simulator/run-generator-kafka.sh b/simulator/run-generator-kafka.sh
@@ -7,8 +7,8 @@ OUTPUT_FORMAT="kafka"
 kafka_properties=$(cat <<OPTIONS
 {
   "bootstrap.servers": "$KAFKA_BROKERS",
-  "sasl.mechanism": "$KAFKA_SASL_MECHANISM",
   "security.protocol": "$KAFKA_SECURITY_PROTOCOL",
+  "sasl.mechanism": "${KAFKA_SASL_MECHANISM:-PLAIN}",
   "sasl.username": "$KAFKA_SASL_USERNAME",
   "sasl.password": "$KAFKA_SASL_PASSWORD"
 }

Original file line number	Diff line number	Diff line change
`@@ -7,8 +7,8 @@ OUTPUT_FORMAT="kafka"`
`7`	`7`	`kafka_properties=$(cat <<OPTIONS`
`8`	`8`	`{`
`9`	`9`	`"bootstrap.servers": "$KAFKA_BROKERS",`
`10`		`- "sasl.mechanism": "$KAFKA_SASL_MECHANISM",`
`11`	`10`	`"security.protocol": "$KAFKA_SECURITY_PROTOCOL",`
	`11`	`+ "sasl.mechanism": "${KAFKA_SASL_MECHANISM:-PLAIN}",`
`12`	`12`	`"sasl.username": "$KAFKA_SASL_USERNAME",`
`13`	`13`	`"sasl.password": "$KAFKA_SASL_PASSWORD"`
`14`	`14`	`}`