search

tarungka / wire

Wire is a distributed open source stream processing framework with powerful stream and batch-processing capabilities.[UNDER DEVELOPEMENT]
GNU General Public License v3.0
2 stars 1 forks source link

BUG(RACE COND): The log file closes before the system shuts down #35

Open tarungka opened 1 month ago

tarungka commented 1 month ago 
{"level":"info","time":1726885552,"message":"Disconnecting kafka sink"}
{"level":"trace","time":1726885552,"message":"The RUN function is done/returning.[Key:mongo_user_pipeline|Name:Kafka User Data|Type:kafka]"}
{"level":"error","error":"client closed","record":{"Key":null,"Value":null,"Headers":null,"Timestamp":"0001-01-01T00:00:00Z","Topic":"foo","Partition":0,"Attrs":{},"ProducerEpoch":0,"ProducerID":0,"LeaderEpoch":0,"Offset":0,"Context":{"Context":{}}},"time":1726885552,"message":"record had a produce error"}
{"level":"info","time":1726885552,"message":"received interrupt signal; closing client"}
{"level":"trace","time":1726885552,"message":"After wait"}
zerolog: could not write event: write server.log: file already closed
{"level":"debug","time":1726885552,"message":"The upstream channel (dataChan) closed"}