And do you know when kafka consumer/producer will be re implemented according to the new source/sink api? I am thinking whether I should adjust the code for now, since I need to re adjust the code when it is reconstructed to the new source/sink api.
yidan zhao <hinobl...@gmail.com> 于2021年3月4日周四 下午4:44写道： > I uploaded a picture to describe that. > https://ftp.bmp.ovh/imgs/2021/03/2068f2e22045e696.png > >>
