From dbfbc9bbeac4c9479fe6340098a7601c8689a52d Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Sat, 15 Oct 2022 20:42:28 +0200
Subject: [PATCH] kafka-pipe: update filter "KafkatorioPacket encoded:::"

---
 modules/infra-kafka-pipe/readme.md         | 2 +-
 modules/infra-kafka-pipe/src/kafka-pipe.sh | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/infra-kafka-pipe/readme.md b/modules/infra-kafka-pipe/readme.md
index 2fc4129..64f2ed8 100644
--- a/modules/infra-kafka-pipe/readme.md
+++ b/modules/infra-kafka-pipe/readme.md
@@ -49,4 +49,4 @@ curl \
   --insecure "http://localhost/v1.41/containers/factorio-server/attach?logs=true&stream=true&stdout=true&follow=true" |
   tail -c+9
 
-```
\ No newline at end of file
+```
diff --git a/modules/infra-kafka-pipe/src/kafka-pipe.sh b/modules/infra-kafka-pipe/src/kafka-pipe.sh
index e6717fd..e0922be 100644
--- a/modules/infra-kafka-pipe/src/kafka-pipe.sh
+++ b/modules/infra-kafka-pipe/src/kafka-pipe.sh
@@ -17,7 +17,7 @@ KEY="${INSTANCE_ID:-none}"
 
 while :; do
   docker logs --tail 0 -f "$FACTORIO_SERVER_CONTAINER_NAME" |
-    sed -n -e 's/^KafkatorioPacket: //p' |
+    sed -n -e 's/^KafkatorioPacket encoded::: //p' |
     kcat -P \
       -b "$KAFKA_HOST" \
       -t kafkatorio.src.server-log \