CryoThrust commented on PR #12088: URL: https://github.com/apache/seatunnel/pull/12088#issuecomment-5539064948
## 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 the magic byte before removing the five-byte wire header. - Preserve existing raw Avro behavior when the option is disabled. - Add regression coverage for framed and malformed payloads. - Update the 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 - `./mvnw -pl seatunnel-formats/seatunnel-format-avro -Dtest=AvroSerializationSchemaTest test` — 7 tests passed - `./mvnw -pl seatunnel-connectors-v2/connector-kafka -DskipTests compile` — passed Apache CI is running the repository-level checks. -- 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]
