From d2aa961e1ae2b28cc670e6cacac66d101c83167a Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Sun, 9 Jan 2022 17:46:17 +0100
Subject: [PATCH] add version header to kafka pipe messages

---
 modules/infra-kafka-pipe/src/kafka-pipe.sh | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/modules/infra-kafka-pipe/src/kafka-pipe.sh b/modules/infra-kafka-pipe/src/kafka-pipe.sh
index b155266..f9fc1ce 100644
--- a/modules/infra-kafka-pipe/src/kafka-pipe.sh
+++ b/modules/infra-kafka-pipe/src/kafka-pipe.sh
@@ -17,7 +17,11 @@ INSTANCE_ID=$(cat /proc/sys/kernel/random/uuid)
 while :; do
   docker logs --tail 0 -f "$FACTORIO_SERVER_CONTAINER_NAME" |
     sed -n -e 's/^KafkatorioPacket: //p' |
-    kcat -P -T -b "$KAFKA_HOST" -t factorio-server-log -k "$INSTANCE_ID"
+    kcat -P -T \
+      -b "$KAFKA_HOST" \
+      -t factorio-server-log \
+      -k "$INSTANCE_ID" \
+      -H "KAFKA-PIPE-VERSION=$KAFKATORIO_VERSION"
 
   echo "Error - retrying in 10 seconds"
   sleep 10