开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

在Flink CDC中使用jdbc连接器写入mysql,中文变成问号了,要加什么配置吗?

在Flink CDC中使用jdbc连接器写入mysql,中文变成问号了,要加什么配置吗?

展开
收起
花开富贵111 2024-07-15 15:49:16 63 0
1 条回答
写回答
取消 提交回答
  • 使用Flink CDC的MySQL连接器写入中文数据出现问号可能是因为字符集设置不一致。请确保Flink作业和MySQL数据库的字符集都支持中文。在Flink的源码或者DDL中设置characterEncoding参数为UTF-8。例如,通过Flink的SQL API可以这样配置:

    CREATE TABLE my_table (
      ...
    ) WITH (
      'connector.type' = 'jdbc',
      'connector.url' = 'jdbc:mysql://localhost:3306/mydb',
      'connector.table' = 'my_table',
      'connector.character-encoding' = 'UTF-8',  -- 添加这一行设置字符集
      ...
    );
    

    确保MySQL数据库的字符集也设置为UTF-8。可参考官方文档

    2024-07-15 16:54:38
    赞同 2 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关镜像