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

tee produced records

Browse source
This commit is contained in:
Adam 2021-10-23 23:10:38 +02:00
parent e526345299
commit 4c14cc2353
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
modules/factorio-events-kafka-pipe/kafka-pipe.sh
View file

@ -13,7 +13,7 @@ endProcess() {
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/^FactorioEvent: //p' | sed -n -e 's/^FactorioEvent: //p' |
kafkacat -P -b "$KAFKA_HOST" -t factorio-server-log kafkacat -P -T -b "$KAFKA_HOST" -t factorio-server-log
echo "Error - retrying in 10 seconds" echo "Error - retrying in 10 seconds"