fix: automatically supplement primary key columns when creating stream