{"record":{"id":"839c7770e92f7963","repo":"nats-io/nats-server","slug":"err","errorCode":null,"errorMessage":"err","messagePattern":"err","errorType":"console","errorClass":null,"httpStatus":null,"severity":"error","filePath":"server/stream.go","lineNumber":3052,"sourceCode":"\t\t}\n\n\t\trespCh := make(chan *JSApiConsumerDeleteResponse, 1)\n\t\treply := infoReplySubject()\n\t\tcdSub, err := acc.subscribeInternal(reply, func(sub *subscription, c *client, _ *Account, subject, reply string, rmsg []byte) {\n\t\t\t_, msg := c.msgParts(rmsg)\n\n\t\t\tvar cdr JSApiConsumerDeleteResponse\n\t\t\tif err := json.Unmarshal(msg, &cdr); err != nil {\n\t\t\t\twarn(err)\n\t\t\t\treturn\n\t\t\t}\n\t\t\tselect {\n\t\t\tcase respCh <- &cdr:\n\t\t\tdefault:\n\t\t\t}\n\t\t})\n\t\tif err != nil {\n\t\t\twarn(err)\n\t\t\treturn\n\t\t}\n\t\tdefer acc.unsubscribeInternal(cdSub)\n\n\t\t// Send the delete request.\n\t\terr = s.sendInternalAccountMsgWithReply(acc, subject, reply, nil, nil, false)\n\t\tif err != nil {\n\t\t\twarn(err)\n\t\t\treturn\n\t\t}\n\t\tselect {\n\t\tcase cdr := <-respCh:\n\t\t\tif cdr.Error != nil {\n\t\t\t\twarn(cdr.Error)\n\t\t\t}\n\t\tcase <-time.After(sourceHealthCheckInterval):\n\t\t\twarn(errors.New(\"timed out\"))\n\t\t}","sourceCodeStart":3034,"sourceCodeEnd":3070,"githubUrl":"https://github.com/nats-io/nats-server/blob/3a66a489d262bf89b71a71c955c94920394532f3/server/stream.go#L3034-L3070","documentation":"In the async consumer-cleanup goroutine, subscribeInternal for the delete-response reply subject failed, so no response can be received. The cleanup for that consumer is abandoned (logged via the warn helper with full context) — there is no retry loop.","triggerScenarios":"Thrown at server/stream.go:3052 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Inspect server subscription limits/resource pressure that caused the internal subscribe failure","Delete the orphaned consumer manually if it remains","Re-run stream deletion or retrigger cleanup if consumers keep accumulating"],"exampleFix":null,"handlingStrategy":"fallback","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"3a66a489d262bf89b71a71c955c94920394532f3","analyzedAt":"2026-09-02T04:41:54.247Z","contentChangedAt":null,"schemaVersion":2},"datasetVersion":"2026-09-08T10:18:20.063Z"}