Support Apache RocketMQ Version Support These Engines Key Features Description Sink Options partition.key.fields [array] Task Example Fake to Rocketmq Simple Rocketmq To Roc...
HTTP Endpoints Kafka Endpoints Pulsar Endpoints Bring your own implementation Apache Hudi provides the ability to post a callback notification about a write commit. This may b...
Flink Apache Iceberg supports both Apache Flink ‘s DataStream API and Table API. See the Multi-Engine Support page for the integration of Apache Flink. Feature support Flink...
Apache Paimon (Incubating) Integration Dependencies Configurations Apache Paimon (Incubating) Operations Apache Paimon(incubating) is a streaming data lake platform that suppo...
Support Kudu Version Support Those Engines Key features Description Data Type Mapping Source Options Task Example Simple: Multiple Table Changelog 2.2.0-beta 2022-09-26 N...
Interoperating with XTable Installation Syncing to XTable Hudi Streamer Extensions Hudi (tables created from 0.14.0 onwards) supports syncing to Iceberg and/or Delta Lake with...
How To Use MySQL-CDC Sink Kafka SeaTunnel supports to interpret cdc record as Debezium-JSON messages publish to mq(kafka) system. This is useful in many cases to leverage this ...