SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
7.93k
stars
1.79k
forks
source link
[Fix][Connector kafka]Fix Kafka consumer stop fetching after TM node restarted #7233
Closed
litiliu closed 2 months ago
Purpose of this pull request
this close #7230
Does this PR introduce any user-facing change?
How was this patch tested?
new UT case has been added.
Check list
release-note
.