{"record":{"id":"20dc070e160d5cd1","repo":"risingwavelabs/risingwave","slug":"additional-column-type-is-not-supported-for-con","errorCode":null,"errorMessage":"additional column type {} is not supported for connector {}, acceptable column types: {:?}","messagePattern":"additional column type (.+?) is not supported for connector (.+?), acceptable column types: (.+?)","errorType":"validation","errorClass":null,"httpStatus":null,"severity":"error","filePath":"src/connector/src/parser/additional_columns.rs","lineNumber":171,"sourceCode":"    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,\n            additional_col_type,\n            inner_field_name,\n            data_type,\n        )\n    });\n\n    let col_desc = match additional_col_type {\n        \"key\" => ColumnDesc::named_with_additional_column(","sourceCodeStart":153,"sourceCodeEnd":189,"githubUrl":"https://github.com/risingwavelabs/risingwave/blob/6469eb736d691e8e9b8a419a57edd6429ca77417/src/connector/src/parser/additional_columns.rs#L153-L189","documentation":"After resolving the connector's compatible additional-column set, build_additional_column_desc checks that the requested additional column type (e.g. 'partition', 'offset', 'header', 'timestamp') is in that set. Requesting a type the connector does support partially (or not at all) bails with this error.","triggerScenarios":"CREATE TABLE/SOURCE with INCLUDE <col> AS name (or include header/key/partition/offset/timestamp options) where the specific column type is not listed for that connector in COMPATIBLE_ADDITIONAL_COLUMNS.","commonSituations":"Adding #header to a connector that only supports #partition and #offset; copying a CREATE TABLE statement between connectors with different support matrices.","solutions":["Remove or change the additional column type to one listed as acceptable for the connector","Use a connector that supports the desired additional column type","Check docs for the connector's supported INCLUDE columns"],"exampleFix":"// before\nCREATE TABLE t (...) WITH (connector='nexmark', include header AS h);\n// after\nCREATE TABLE t (...) WITH (connector='kafka', include header AS h);","handlingStrategy":"validation","validationCode":"const KAFKA_COLS = ['partition','offset','timestamp','header','key'];\nfunction validateInclude(connector, colType) {\n  const allowed = { kafka: KAFKA_COLS, nexmark: [], pulsar: ['message_id','partition'] }[connector] || [];\n  if (!allowed.includes(colType)) throw new Error(`${colType} unsupported for ${connector}`);\n}","typeGuard":null,"tryCatchPattern":"try {\n  await rw.query(ddl);\n} catch (e) {\n  if (/additional column type .* is not supported/.test(e.message)) {\n    // remove/rename the offending INCLUDE column and retry\n  } else throw e;\n}","preventionTips":["Check per-connector INCLUDE support matrix before writing DDL","Don't copy INCLUDE clauses across different connectors","Keep a lint script that cross-checks WITH connector vs INCLUDE columns"],"tags":["source","additional-columns","connector","validation"],"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"}