{"record":{"id":"4b539d21bbc18d32","repo":"risingwavelabs/risingwave","slug":"additional-column-is-not-supported-for-connector","errorCode":null,"errorMessage":"additional column is not supported for connector {}, acceptable connectors: {:?}","messagePattern":"additional column is not supported for connector (.+?), acceptable connectors: (.+?)","errorType":"validation","errorClass":null,"httpStatus":null,"severity":"error","filePath":"src/connector/src/parser/additional_columns.rs","lineNumber":163,"sourceCode":"\npub fn build_additional_column_desc(\n    column_id: ColumnId,\n    connector_name: &str,\n    additional_col_type: &str,\n    column_alias: Option<String>,\n    inner_field_name: Option<&str>,\n    data_type: Option<&DataType>,\n    reject_unknown_connector: bool,\n    is_cdc_backfill_table: bool,\n) -> ConnectorResult<ColumnDesc> {\n    let compatible_columns = match (\n        get_supported_additional_columns(connector_name, is_cdc_backfill_table),\n        reject_unknown_connector,\n    ) {\n        (Some(compat_cols), _) => compat_cols,\n        (None, false) => &COMMON_COMPATIBLE_ADDITIONAL_COLUMNS,\n        (None, true) => {\n            bail!(\n                \"additional column is not supported for connector {}, acceptable connectors: {:?}\",\n                connector_name,\n                COMPATIBLE_ADDITIONAL_COLUMNS.keys(),\n            );\n        }\n    };\n    if !compatible_columns.contains(additional_col_type) {\n        bail!(\n            \"additional column type {} is not supported for connector {}, acceptable column types: {:?}\",\n            additional_col_type,\n            connector_name,\n            compatible_columns\n        );\n    }\n\n    let column_name = column_alias.unwrap_or_else(|| {\n        gen_default_addition_col_name(\n            connector_name,","sourceCodeStart":145,"sourceCodeEnd":181,"githubUrl":"https://github.com/risingwavelabs/risingwave/blob/6469eb736d691e8e9b8a419a57edd6429ca77417/src/connector/src/parser/additional_columns.rs#L145-L181","documentation":"When creating a source/table with additional columns (e.g. #partition, #offset, message headers), build_additional_column_desc looks up the connector in COMPATIBLE_ADDITIONAL_COLUMNS. If the connector supports no additional columns at all and it is a CDC backfill table (None, true branch), creation fails naming the connector and the acceptable connectors list.","triggerScenarios":"CREATE TABLE ... WITH (connector='<name>', ...) requesting an additional column (or using CDC backfill which implicitly adds offset columns) for a connector not present in COMPATIBLE_ADDITIONAL_COLUMNS.","commonSituations":"Using additional columns like #key or #timestamp with a connector that doesn't support them (e.g. some CDC or custom connectors); typo in the connector name; using a CDC backfill table with an incompatible connector.","solutions":["Use a supported connector (check the acceptable connectors list in the message)","Remove the additional column from the table definition","Upgrade RisingWave — connector support for additional columns grows over time"],"exampleFix":"// before\nCREATE TABLE t (...) WITH (connector='my_connector', include offset AS #offset);\n// after\nCREATE TABLE t (...) WITH (connector='kafka', include offset AS #offset);","handlingStrategy":"validation","validationCode":"const SUPPORTED = ['kafka','pulsar','kinesis','nats','mqtt','google_pubsub'];\nfunction canAddColumns(connector) {\n  if (!SUPPORTED.includes(connector)) throw new Error(`additional column unsupported for ${connector}`);\n}","typeGuard":null,"tryCatchPattern":"try {\n  await rw.query(ddl);\n} catch (e) {\n  if (/additional column is not supported for connector/.test(e.message)) {\n    // drop INCLUDE clauses or switch connector and retry\n  } else throw e;\n}","preventionTips":["Only add INCLUDE columns on connectors listed in docs as supporting them","Verify connector name spelling in WITH options","For CDC backfill tables, confirm the connector supports offset columns"],"tags":["source","additional-columns","connector"],"backgroundTag":"unsupported-config-value","analyzedSha":"6469eb736d691e8e9b8a419a57edd6429ca77417","analyzedAt":"2026-09-11T21:06:21.487Z","contentChangedAt":"2026-09-11T21:06:21.487Z","schemaVersion":2},"datasetVersion":"2026-09-14T16:17:12.679Z"}