This is an automated email from the ASF dual-hosted git repository.
corgy pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 94d6f5c675 [Fix][docs]fix schema-feature.md doc error (#10413)
add 6948d3492e [Feat][Connector-v2][Kafka] Add support for Schema Registry
wire format in Protobuf deserialization (#10183)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/Kafka.md | 56 +++++-
docs/zh/connectors/source/Kafka.md | 54 ++++++
.../seatunnel/kafka/config/KafkaSourceOptions.java | 9 +
.../seatunnel/kafka/source/KafkaSourceConfig.java | 10 +-
.../seatunnel/kafka/source/KafkaSourceFactory.java | 5 +
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 100 +++++++++++
...chema_registry_header_transform_to_assert.conf} | 10 +-
.../protobuf/ProtobufDeserializationSchema.java | 15 +-
...RegistryAwareProtobufDeserializationSchema.java | 129 ++++++++++++++
...stryAwareProtobufDeserializationSchemaTest.java | 192 +++++++++++++++++++++
10 files changed, 573 insertions(+), 7 deletions(-)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/protobuf/{kafka_protobuf_transform_to_assert.conf
=> kafka_protobuf_schema_registry_header_transform_to_assert.conf} (94%)
create mode 100644
seatunnel-formats/seatunnel-format-protobuf/src/main/java/org/apache/seatunnel/format/protobuf/SchemaRegistryAwareProtobufDeserializationSchema.java
create mode 100644
seatunnel-formats/seatunnel-format-protobuf/src/test/java/org/apache/seatunnel/format/protobuf/SchemaRegistryAwareProtobufDeserializationSchemaTest.java
