{"record":{"id":"ec3f41889c364b86","repo":"risingwavelabs/risingwave","slug":"mqtt-sink-encode-unsupported","errorCode":null,"errorMessage":"mqtt sink encode unsupported: {:?}","messagePattern":"mqtt sink encode unsupported: (.+?)","errorType":"validation","errorClass":"SinkError::Config","httpStatus":null,"severity":"error","filePath":"src/connector/src/sink/mqtt.rs","lineNumber":275,"sourceCode":"                        &format_desc.options,\n                        config.topic.as_deref().unwrap_or(name),\n                        None,\n                    )\n                    .await\n                    .map_err(|e| SinkError::Config(anyhow!(e)))?;\n                    let header = match sid {\n                        None => ProtoHeader::None,\n                        Some(sid) => ProtoHeader::ConfluentSchemaRegistry(sid),\n                    };\n                    RowEncoderWrapper::Proto(ProtoEncoder::new(\n                        schema.clone(),\n                        None,\n                        descriptor,\n                        header,\n                    )?)\n                }\n                _ => {\n                    return Err(SinkError::Config(anyhow!(\n                        \"mqtt sink encode unsupported: {:?}\",\n                        format_desc.encode,\n                    )));\n                }\n            },\n            _ => {\n                return Err(SinkError::Config(anyhow!(\n                    \"MQTT sink only supports append-only mode\"\n                )));\n            }\n        };\n        let qos = config.common.qos();\n\n        let (client, mut eventloop) = config\n            .common\n            .build_client(actor_id, sink_id.as_raw_id())\n            .map_err(|e| SinkError::Mqtt(anyhow!(e)))?;\n","sourceCodeStart":257,"sourceCodeEnd":293,"githubUrl":"https://github.com/risingwavelabs/risingwave/blob/6469eb736d691e8e9b8a419a57edd6429ca77417/src/connector/src/sink/mqtt.rs#L257-L293","documentation":"Raised in MqttSinkWriter::new when building the row encoder: the FORMAT ... ENCODE ... combination requested for the MQTT sink is not supported by the encoder dispatch. The message includes the debug-formatted unsupported format/encode descriptor so the user can pick a supported one.","triggerScenarios":"Thrown at src/connector/src/sink/mqtt.rs:275 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Use a supported ENCODE for the MQTT sink (JSON, or protobuf with a schema registry/subject id configured).","If using PROTOBUF, provide valid schema registry settings or an inline schema so ProtoEncoder can be built."],"exampleFix":null,"handlingStrategy":"validation","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"6469eb736d691e8e9b8a419a57edd6429ca77417","analyzedAt":"2026-09-11T21:06:21.487Z","contentChangedAt":"2026-09-11T21:06:21.487Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}