Xiaojian Sun

RocketMQ verison ： 4.7.0 1. The seek method in DefaultLitePullConsumerImpl defaults to the rebrance method. However, if I want to customize the MessageQueueListener, it seems that I cannot use the...

[improve][connector]Debezium mysql supports read-only incremental snapshot mode

1

Fixes #18256 ### Motivation https://debezium.io/blog/2022/04/07/read-only-incremental-snapshots/ ### Modifications Overwrite MySqlReadOnlyIncrementalSnapshotContext and MySqlReadOnlyIncrementalSnapshotChangeEventSource in debezium. ### Verifying this change - [x] Make sure that the change passes the CI checks. ### Does...

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description Support for deploying flink 1.15 on k8s ### Usage Scenario...

[Feature][connector][kafka] Support read debezium format message from kafka

2

https://github.com/apache/seatunnel/issues/3743 Support read debezium format message from kafka ## Check list * [ ] Code changed are covered with tests, or it does not need tests for reason: * [...

[Feature][SeaTunnel Engine IMap Storage] Imap storage supports kafka compact topic in cluster mode

9

## Purpose of this pull request ## Check list * [ ] Code changed are covered with tests, or it does not need tests for reason: * [ ] If...

[Feature][Connector-V2] connector-kafka source support data conversion extracted by kafka connect source

3

## Purpose of this pull request #4137 ## Check list * [ ] Code changed are covered with tests, or it does not need tests for reason: * [ ]...

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description Checkpoint storage supports kafka compact topic ### Usage Scenario _No...

[Feature] Support Flink read / write data branch

6

### Purpose Linked issue: close (https://github.com/apache/incubator-paimon/issues/2861) When writing and reading branch data for Flink, it was found that if the "TableCommitImpl newcommit (String commitUser, String branchName)" interface is added like...

[Feature]Implement replace branch in BranchManager

10

### Purpose Linked issue: close https://github.com/apache/incubator-paimon/issues/2153 ### Tests BranchActionITCase.testReplaceBranchToTargetBranch ### API and Format ### Documentation

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Paimon supports Nessie catalog（https://projectnessie.org/nessie-latest/） ### Solution _No response_ ### Anything else? _No response_...