From 514923e463eb7516bc04568c80878d73622d6640 Mon Sep 17 00:00:00 2001
From: jbeemster <joshua.a.beemster@gmail.com>
Date: Wed, 4 Oct 2023 14:55:57 +0800
Subject: [PATCH] Add client ids

---
 templates/config.hocon.tmpl | 2 ++
 templates/user-data.sh.tmpl | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/templates/config.hocon.tmpl b/templates/config.hocon.tmpl
index 9342cd2..e1ceb50 100644
--- 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
index dda1cce..8f66e5b 100644
--- 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