{"record":{"id":"039b66314b72b436","repo":"SigNoz/signoz","slug":"partition-not-found-in-the-request","errorCode":null,"errorMessage":"partition not found in the request","messagePattern":"partition not found in the request","errorType":"validation","errorClass":null,"httpStatus":400,"severity":"warning","filePath":"pkg/query-service/app/integrations/messagingQueues/kafka/translator.go","lineNumber":55,"sourceCode":"\t\tVersion:        \"v4\",\n\t\tFormatForWeb:   true,\n\t}\n\n\treturn queryRangeParams, nil\n}\n\nfunc buildClickHouseQueryNetwork(messagingQueue *MessagingQueue, queueType string) (*v3.ClickHouseQuery, error) {\n\tstart := messagingQueue.Start\n\tend := messagingQueue.End\n\n\tconsumerGroup, ok := messagingQueue.Variables[\"consumer_group\"]\n\tif !ok {\n\t\treturn nil, fmt.Errorf(\"consumer_group not found in the request\")\n\t}\n\n\tpartitionID, ok := messagingQueue.Variables[\"partition\"]\n\tif !ok {\n\t\treturn nil, fmt.Errorf(\"partition not found in the request\")\n\t}\n\n\tquery := generateNetworkLatencyThroughputSQL(start, end, consumerGroup, partitionID, queueType)\n\treturn &v3.ClickHouseQuery{\n\t\tQuery: query,\n\t}, nil\n}\n\nfunc buildBuilderQueriesProducerBytes(\n\tunixMilliStart, unixMilliEnd int64,\n\tattributeCache *Clients,\n) (map[string]*v3.BuilderQuery, error) {\n\n\tbq := make(map[string]*v3.BuilderQuery)\n\tqueryName := \"byte_rate\"\n\n\tchq := &v3.BuilderQuery{\n\t\tQueryName:    queryName,","sourceCodeStart":37,"sourceCodeEnd":73,"githubUrl":"https://github.com/SigNoz/signoz/blob/5069bf80b08f1f00d7e014eccc09902f9871004f/pkg/query-service/app/integrations/messagingQueues/kafka/translator.go#L37-L73","documentation":"Error returned by buildClickHouseQueryNetwork when the 'partition' key is absent from messagingQueue.Variables; both consumer_group and partition are mandatory for network-latency queries.","triggerScenarios":"Requesting Kafka network latency/throughput data without a partition variable in the request.","commonSituations":"Clients omit the partition template variable, or dashboards default it to empty when no partition is selected.","solutions":["Include partition in the variables map","Provide a partition selector/default in the dashboard","Validate variables before issuing the request"],"exampleFix":"// before\nVariables: map[string]string{\"consumer_group\": \"my-group\"}\n\n// after\nVariables: map[string]string{\"consumer_group\": \"my-group\", \"partition\": \"0\"}","handlingStrategy":"validation","validationCode":"if (!('partition' in mq.Variables)) throw new Error('partition required');","typeGuard":"func hasRequiredVars(v map[string]string, keys ...string) bool { for _, k := range keys { if _, ok := v[k]; !ok { return false } }; return true }","tryCatchPattern":null,"preventionTips":["Include partition variable alongside consumer_group","Validate variables client-side"],"tags":["kafka","messaging-queues","validation"],"backgroundTag":"missing-request-parameter","analyzedSha":"5069bf80b08f1f00d7e014eccc09902f9871004f","analyzedAt":"2026-08-28T06:22:12.824Z","schemaVersion":2},"datasetVersion":"2026-08-28T11:17:15.048Z"}