apache/seatunnel

[Umbrella][Feature][Connector] Implement multi-table sink support for connectors

Chiusa

#10.426 aperta il 31 gen 2026

 (20 commenti) (0 reazioni) (0 assegnatari)Java (1432 fork)batch import
featuregood first issuehelp wanted

Metriche repository

Star
 (6897 stelle)
Metriche merge PR
 (Merge medio 13g 21h) (143 PR mergiate in 30 g)

Descrizione

Description

Based on the tracking issue #5652 and codebase analysis, many sink connectors still lack support for the SupportMultiTableSink interface. We are looking for contributors to help implement this feature for the remaining connectors.

Implementing SupportMultiTableSink allows the connector to handle multiple tables in a single sink instance, which is crucial for database synchronization scenarios (e.g., CDC).

Connectors to be implemented

Type Connector Contributer Status PR
Sink AmazonDynamodb @Best2Two Done #10497
Sink Cassandra Todo
Sink DingTalk Todo
Sink Feishu Todo
Sink GoogleFirestore Todo
Sink IoTDB Todo
Sink Neo4j Todo
Sink Pulsar @Muktha9491 Doing #10558, #10670
Sink RabbitMQ @Gardenia-zx Doing
Sink Rocketmq @onceMisery Doing
Sink S3Redshift Todo
Sink SelectDBCloud Todo
Sink Sentry Todo
Sink Slack Todo
Sink Socket Todo
Sink Tablestore Todo
Sink Kafka @misi1987107 Doing #10154

How to Contribute

  1. Pick a connector: Choose one from the list above.
  2. Claim the task: Comment on this issue (e.g., "I would like to work on AmazonDynamodb").
  3. Implement:
    • Modify the Sink class to implement the org.apache.seatunnel.api.sink.SupportMultiTableSink interface.
    • Update the SinkFactory to handle CatalogTables correctly.
    • Ensure tables_configs or equivalent logic is handled if necessary (though Sink usually relies on the upstream CatalogTable).
  4. Reference:
    • You can refer to the implementation of JdbcSink or ElasticsearchSink.
  5. Submit PR: Submit a Pull Request and link it to this issue.

Thank you for your contribution! Please leave a message if you‘d like to implement the multi - table sink feature for any connector.

Guida contributor