From 8b11670a692d97e141781311e3a7c544e7fc251a Mon Sep 17 00:00:00 2001
From: Adam <897017+asemy@users.noreply.github.com>
Date: Mon, 25 Oct 2021 23:22:23 +0200
Subject: [PATCH] kafka-pipe - use a random key for messages

---
 modules/factorio-events-kafka-pipe/kafka-pipe.sh | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/modules/factorio-events-kafka-pipe/kafka-pipe.sh b/modules/factorio-events-kafka-pipe/kafka-pipe.sh
index e0f5b7b..1c7aae1 100644
--- a/modules/factorio-events-kafka-pipe/kafka-pipe.sh
+++ b/modules/factorio-events-kafka-pipe/kafka-pipe.sh
@@ -10,12 +10,15 @@ endProcess() {
   exit
 }
 
+# some random ID, to use as a message key
+INSTANCE_ID=$(cat /proc/sys/kernel/random/uuid)
+
 while :; do
   docker logs --tail 0 -f "$FACTORIO_SERVER_CONTAINER_NAME" |
     sed -n -e 's/^FactorioEvent: //p' |
-    kafkacat -P -T -b "$KAFKA_HOST" -t factorio-server-log
+    kafkacat -P -T -b "$KAFKA_HOST" -t factorio-server-log -k "$INSTANCE_ID"
 
   echo "Error - retrying in 10 seconds"
-
   sleep 10
+
 done