+ 读取 kafka 数据源(source) 插入模式
![[935618a04697874b38ab1332296451c.png]]

+ 写入 kafka 数据源（slink） upsert模式 (设置主键)
![[Pasted image 20250210112334.png]]