After switch to managed kafka Patch reports errors and restarts frequently:

{{
{"@timestamp":"2022-10-26T09:08:26.456Z","level":"error","message":"error initializing the kafka reader for partition 13 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:26.456Z","level":"error","message":"error initializing the kafka reader for partition 43 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:26.456Z","level":"error","message":"error initializing the kafka reader for partition 22 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:26.457Z","level":"error","message":"error initializing the kafka reader for partition 34 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:26.457Z","level":"error","message":"error initializing the kafka reader for partition 62 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:27.443Z","level":"error","message":"error initializing the kafka reader for partition 18 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:28.155Z","level":"error","message":"error initializing the kafka reader for partition 51 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"} {"@timestamp":"2022-10-26T09:08:28.871Z","level":"error","message":"error initializing the kafka reader for partition 9 of platform-mq-prod.patchman.evaluator.upload: context canceled","type":"kafka"}
{"@timestamp":"2022-10-26T09:08:38.873Z","err":"use of closed network connection","level":"error","message":"Panicked","stack":"goroutine 215 [running]:|runtime/debug.Stack()|\t/usr/lib/golang/src/runtime/debug/stack.go:24 +0x65|app/base/utils.LogPanics(0x1)|\t/go/src/app/base/utils/core.go:140 +0x58|panic(

)|\t/usr/lib/golang/src/runtime/panic.go:1038 +0x215|app/base/mqueue.(*kafkaGoReaderImpl).HandleMessages(0xc00e90dc00, 0xc0226d2340)|\t/go/src/app/base/mqueue/mqueue_impl_gokafka.go:45 +0x548|app/base/mqueue.runReader(0xc00b2e7770, {0xc000039500, 0xc000504fd0}, 0x6bd806, 0xc007ef80c0)|\t/go/src/app/base/mqueue/mqueue.go:75 +0xdd|created by app/base/mqueue.SpawnReader|\t/go/src/app/base/mqueue/mqueue.go:80 +0xd6|"}
}}