Add client ids

snowplow-devops · Oct 4, 2023 · 514923e · 514923e
1 parent ffb4eac
commit 514923e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/templates/config.hocon.tmpl b/templates/config.hocon.tmpl
@@ -3,6 +3,7 @@
     "topicName": "${enriched_topic_name}"
     "bootstrapServers": "${kafka_brokers}"
     "consumerConf": {
+      "client.id": $${CONSUMER_CLIENT_ID},
       "security.protocol": "SASL_SSL",
       "sasl.mechanism": "PLAIN",
       "sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${enriched_topic_kafka_username}\" password=\"${enriched_topic_kafka_password}\";"
@@ -19,6 +20,7 @@
       "topicName": "${bad_topic_name}"
       "bootstrapServers": "${kafka_brokers}"
       "producerConf": {
+        "client.id": $${PRODUCER_BAD_CLIENT_ID},
         "security.protocol": "SASL_SSL",
         "sasl.mechanism": "PLAIN",
         "sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${bad_topic_kafka_username}\" password=\"${bad_topic_kafka_password}\";"

diff --git a/templates/user-data.sh.tmpl b/templates/user-data.sh.tmpl
@@ -24,6 +24,8 @@ sudo docker run \
   --env AZURE_CLIENT_SECRET=${client_secret} \
   --env JDK_JAVA_OPTIONS='${java_opts}' \
   --env INSTANCE_ID=$(get_instance_id) \
+  --env CONSUMER_CLIENT_ID="$${HOSTNAME}" \
+  --env PRODUCER_BAD_CLIENT_ID="$${HOSTNAME}-bad" \
   snowplow/lake-loader-azure:${version} \
   --iglu-config /snowplow/config/iglu_config.json \
   --config /snowplow/config/config.hocon