{"record":{"id":"d9eae71407b685e8","repo":"t8y2/dbx","slug":"rocketmq-error-d-s","errorCode":null,"errorMessage":"RocketMQ error %d: %s","messagePattern":"RocketMQ error (.+?): (.+?)","errorType":"exception","errorClass":null,"httpStatus":null,"severity":"error","filePath":"agents/drivers/rocketmq/remoting.go","lineNumber":39,"sourceCode":") (*remoting.RemotingCommand, error) {\n\tclient := remoting.NewClient(address, connectTimeout)\n\tif err := client.Connect(); err != nil {\n\t\treturn nil, err\n\t}\n\tdefer client.Close()\n\tresponse, err := client.InvokeSync(ctx, command)\n\tif err != nil {\n\t\treturn nil, err\n\t}\n\tallowed := false\n\tfor _, code := range allowedCodes {\n\t\tif response.Code == code {\n\t\t\tallowed = true\n\t\t\tbreak\n\t\t}\n\t}\n\tif !allowed {\n\t\treturn nil, fmt.Errorf(\"RocketMQ error %d: %s\", response.Code, response.Remark)\n\t}\n\treturn response, nil\n}\n","sourceCodeStart":21,"sourceCodeEnd":43,"githubUrl":"https://github.com/t8y2/dbx/blob/c0390bff16418b651f4728520d99adf8ce48829a/agents/drivers/rocketmq/remoting.go#L21-L43","documentation":"Returned by invokeRemotingAllowCodes in the rocketmq driver when a synchronous remoting request succeeded at the transport level but the response code is not in the allowed-codes set for that operation. The message shows the RocketMQ response code (e.g. topic not exist, no permission, system error) and the server's remark string.","triggerScenarios":"Thrown at agents/drivers/rocketmq/remoting.go:39 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Map the numeric code to its RocketMQ meaning (e.g. 17=QUEUE_NOT_EXIST-like errors, 16 message illegal, 1 system error) and follow the remark hint","For topic/group errors verify the topic exists and the group id is correct","For permission errors check ACL access_key/secret_key and broker ACL config","Retry transient system-error codes; fix configuration for permanent ones"],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"c0390bff16418b651f4728520d99adf8ce48829a","analyzedAt":"2026-09-05T23:05:10.900Z","contentChangedAt":"2026-09-05T23:05:10.900Z","schemaVersion":2},"datasetVersion":"2026-09-14T05:17:10.506Z"}