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 \