场景: 同时每隔30s 抽取N张Mysql的数据表,根据时间字段抽取 自定义的Source 能否通过设置Source的并行度 比如有十张表,设置并行度为3 根据并行度动态分配抽取的表 类似根据并行度和kafka的分区的关系 在一个source里,所有数据混合一起发往下游
[email protected]
场景: 同时每隔30s 抽取N张Mysql的数据表,根据时间字段抽取 自定义的Source 能否通过设置Source的并行度 比如有十张表,设置并行度为3 根据并行度动态分配抽取的表 类似根据并行度和kafka的分区的关系 在一个source里,所有数据混合一起发往下游
[email protected]