flink-CDC 中文乱码问题

[Li,Qian(DXM,PB)]

你好：
我在使用Flink CDC SQL CLI向ES6写数据的时候，
由于原数据库编码形式是latin1，这样往ES中写入的中文数据就是乱码了，
请问有什么解决方式么，可以进行编码转换？
谢谢！

李倩