lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

kafka-pipe: update filter "KafkatorioPacket encoded:::"

Browse source
This commit is contained in:
Adam 2022-10-15 20:42:28 +02:00
parent 6a439b334d
commit dbfbc9bbea
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
modules/infra-kafka-pipe/readme.md
View file

@ -49,4 +49,4 @@ curl \
--insecure "http://localhost/v1.41/containers/factorio-server/attach?logs=true&stream=true&stdout=true&follow=true" | --insecure "http://localhost/v1.41/containers/factorio-server/attach?logs=true&stream=true&stdout=true&follow=true" |
tail -c+9 tail -c+9
``` ```

2
modules/infra-kafka-pipe/src/kafka-pipe.sh
View file

@ -17,7 +17,7 @@ KEY="${INSTANCE_ID:-none}"
while :; do while :; do
docker logs --tail 0 -f "$FACTORIO_SERVER_CONTAINER_NAME" | docker logs --tail 0 -f "$FACTORIO_SERVER_CONTAINER_NAME" |
sed -n -e 's/^KafkatorioPacket: //p' | sed -n -e 's/^KafkatorioPacket encoded::: //p' |
kcat -P \ kcat -P \
-b "$KAFKA_HOST" \ -b "$KAFKA_HOST" \
-t kafkatorio.src.server-log \ -t kafkatorio.src.server-log \