search

tarungka / wire

Just a realtime connector to keep source and sink in sync near realtime[UNDER DEVELOPEMENT]
1 stars 1 forks source link

BUG(kakfa sink): The producer once closed, wants to produce messages. #36

Open tarungka opened 1 hour ago

tarungka commented 1 hour 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"}
tarungka commented 1 hour ago

Unsure atm as to why this is happening, probably its trying to send some metadata to the kakfa about its state or to close connection.