SEZ9 commented on issue #11620: URL: https://github.com/apache/seatunnel/issues/11620#issuecomment-5162460490
Confirmed contract mismatch: PulsarBaseOptions.FORMAT and PulsarSourceFactory OptionRule advertise 'text' (with field_delimiter), but PulsarMultiTableConfig.validateFormat() only allows JSON/CANAL_JSON/AVRO and PulsarSource.createDeserialization() has no TEXT branch. Preferred fix: add TEXT support to the source using TextDeserializationSchema (seatunnel-format-text is already a dependency, and the sink already supports text via TextSerializationSchema). Add a TEXT branch in createDeserialization(), allow TEXT in validateFormat(), and cover it with an e2e/unit test. Alternative if text source support is intentionally unsupported: remove 'text' from FORMAT description, drop the field_delimiter binding for text in PulsarSourceFactory, and update the source docs accordingly. Please indicate which direction is desired; a PR would be welcome. <!-- streview-comment:45 --> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
