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 275adcce13 [Fix][connector-cdc] Fix NPE when finishing snapshot split
due to null splitId (#10404)
add 4d12727ad9 [Fix][Connectors-v2] Fix transaction cancellation failure
after broker recovery (#10013)
No new revisions were added by this update.
Summary of changes:
.../kafka/sink/KafkaInternalProducer.java | 7 +
.../kafka/sink/KafkaTransactionSender.java | 2 +-
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 159 ++++++++++++++++-----
.../kafka/kafka_to_kafka_exactly_once_batch.conf | 4 +-
.../kafka_to_kafka_exactly_once_streaming.conf | 15 +-
5 files changed, 149 insertions(+), 38 deletions(-)
