参数 | 说明 |
数据源 | 选择当前项目中可用的 Kafka 数据源,Kafka 写入端数据源类型支持 Kafka、Ckafka 。 |
Topic | Kafka 数据源中的 Topic。 |
序列化格式 | Kafka 消息序列化格式类型,支持三种类型: canal-json json avro |
写入模式 | Kafka 支持两种写入模式: append:追加写入。 upsert:以 upsert 方式插入消息,设置后消息仅只能被消息端处理一次以保证 Exactly-Once。 |
唯一键 | Upsert 写入模式下,需设置唯一键保证数据有序性,支持多选,Append 模式则不需要设置唯一键。 |
高级设置(可选) | 可根据业务需求配置参数。 |