This is an automated email from the ASF dual-hosted git repository.
liugddx pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 3cdb7cfa4 [Bug][Connector-v2][KafkaSink]Fix the permission problem
caused by client.id. (#4246)
add 71f4d0c78 [Bug][Connector-v2][KafkaSource]Fix KafkaConsumerThread exit
caused by commit offset error. (#4379)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/kafka/source/KafkaConsumerThread.java | 2 +-
.../connectors/seatunnel/kafka/source/KafkaSourceReader.java | 11 +++++++----
2 files changed, 8 insertions(+), 5 deletions(-)
