This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from cc021bd2c [Zeta] [Fix] Fix some operation didn't use classloader which
belong task (#4611)
add 93471c9ad [hotfix][e2e][kafka] Fix the job not stopping (#4600)
No new revisions were added by this update.
Summary of changes:
.../kafka/source/KafkaSourceSplitEnumerator.java | 8 +-
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 4 +
.../kafka/kafkasource_earliest_to_console.conf | 61 +++++++-------
...ce_format_error_handle_way_fail_to_console.conf | 97 ++++++++++-----------
...ce_format_error_handle_way_skip_to_console.conf | 98 +++++++++++-----------
.../kafka/kafkasource_group_offset_to_console.conf | 62 +++++++-------
.../kafka/kafkasource_latest_to_console.conf | 62 +++++++-------
.../kafkasource_specific_offsets_to_console.conf | 66 ++++++++-------
.../kafka/kafkasource_timestamp_to_console.conf | 64 +++++++-------
.../resources/kafkasource_json_to_console.conf | 95 +++++++++++----------
.../resources/kafkasource_text_to_console.conf | 95 +++++++++++----------
11 files changed, 376 insertions(+), 336 deletions(-)
