FlinkCDC连接tidb乱码

sql方式可以,只是读了一段时间数据,报了个 java.io.EOFException异常。就想着换成api方式,调试下原因