Flink作业读取mysql-binlog写入kafka报错

问题描述

flinkcdc读取mysql-binlog日志写到kafka时出现不能获取kafka metadata的问题

遇到获取不到获取不到metadata的情况,检查kafka集群是否有节点挂了。我们kafka集群为3节点,排查发现其中一个节点由于磁盘写满挂了。


觉得不错的话,给点打赏吧 ୧(๑•̀⌄•́๑)૭



wechat pay



alipay

Flink作业读取mysql-binlog写入kafka报错
http://yuting0907.github.io/2022/08/31/Flink作业读取mysql-binlog写入kafka报错/
作者
Echo Yu
发布于
2022年8月31日
许可协议