add version header to kafka pipe messages

2022-01-09 17:46:17 +01:00 · 2022-01-09 17:46:17 +01:00 · d2aa961e1a
commit d2aa961e1a
parent b5de2132a1
1 changed files with 5 additions and 1 deletions
--- 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