CryoThrust opened a new pull request, #12088: URL: https://github.com/apache/seatunnel/pull/12088
## What is included - Add opt-in Confluent Avro wire-header stripping to `AvroDeserializationSchema`. - Reuse `strip_schema_registry_header`; for Avro it requires `avro_schema` and validates magic byte `0` plus the fixed five-byte header. - Keep raw Avro behavior unchanged when the option is disabled. - Add framed-payload and malformed-header regression tests. - Update English and Chinese Kafka/Avro documentation. The schema ID remains opaque; this change does not add Schema Registry network calls or dependencies. Closes #12054 ## Verification - `mvn -s /Users/yohanes/.m2/settings-public-central.xml -pl seatunnel-formats/seatunnel-format-avro -DskipCheckstyleTests -Dlicense.skip=true -Dspotless.check.skip=true -Dtest=AvroSerializationSchemaTest test` - `mvn -s /Users/yohanes/.m2/settings-public-central.xml -pl seatunnel-connectors-v2/connector-kafka -DskipTests -DskipCheckstyleTests -Dlicense.skip=true -Dspotless.check.skip=true compile` -- 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]
