This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 0a6401797a [Fix][Connector-V2] Skip CSV preamble before parsing the
header (#12936)
add befdd36552 [Fix][Connector-V2][Kafka] Skip a Kafka tombstone instead
of failing the Avro source (#12927)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/Kafka.md | 11 +++
docs/zh/connectors/source/Kafka.md | 9 ++
.../seatunnel/kafka/source/KafkaRecordEmitter.java | 13 ++-
.../kafka/source/KafkaRecordEmitterTest.java | 95 ++++++++++++++++++++++
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 35 ++++++++
...rt.conf => kafka_avro_tombstone_to_assert.conf} | 33 ++++----
.../format/avro/AvroDeserializationSchema.java | 4 +
.../format/avro/AvroSerializationSchemaTest.java | 24 ++++++
8 files changed, 204 insertions(+), 20 deletions(-)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/avro/{kafka_avro_to_assert.conf
=> kafka_avro_tombstone_to_assert.conf} (84%)
