zhiliang-wu commented on PR #11112: URL: https://github.com/apache/seatunnel/pull/11112#issuecomment-4740524993
Thanks for the review and the great catch on the format compatibility! I've updated the PR to address your feedback. **Changes made:** **Added Strict Validation (KafkaSinkWriter.java):** I've explicitly scoped kafka_message_value_fields to only allow compatible formats. If a user configures this option while using native, compatible_debezium_json, or compatible_kafka_connect_json formats, the connector will now immediately reject it and throw a clear KafkaConnectorException (OPERATION_NOT_SUPPORTED) to prevent any silent failures or broken runtime behavior. **Updated Documentation:** I've added notes to both the English (docs/en/connectors/sink/Kafka.md) and Chinese (docs/zh/connectors/sink/Kafka.md) documentation explicitly stating that kafka_message_value_fields is not supported for those three formats. -- 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]
