This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from ebb64f14bd [Improve][Formats] Replace
`CommonErrorCodeDeprecated.JSON_OPERATION_FAILED` (#5948)
add d4caef71cb [Fix] Fix Debezium format cannot parse date/time/timestamp
(#5887)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/api/table/catalog/CatalogTable.java | 4 +
.../e2e/connector/kafka/KafkaFormatIT.java | 375 ++++++++++++++++++---
.../src/test/resources/debezium/debezium_data.txt | 14 +-
.../kafkasource_debezium_cdc_to_pgsql.conf | 108 +++++-
.../kafkasource_debezium_to_kafka.conf | 44 ++-
...ompatibleDebeziumJsonDeserializationSchema.java | 3 +-
.../CompatibleDebeziumJsonSerializationSchema.java | 1 -
.../debezium/json/DebeziumJsonConverter.java | 4 +-
seatunnel-formats/seatunnel-format-json/pom.xml | 2 -
.../DebeziumJsonDeserializationSchema.java | 6 +-
.../format/json/debezium/DebeziumRowConverter.java | 151 +++++++++
11 files changed, 641 insertions(+), 71 deletions(-)
create mode 100644
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/debezium/DebeziumRowConverter.java
