Hi, Let's assume we have two stream, order stream& order detail stream, they are from mysql binlog.
Table `order` schema: id primary key, order_id and order_status Table `order_detail` schema: id primary key, order_id and quantity one order item have several order_detail items if we have following data sequence: order -- best wishes hengyu