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/posts/61250184.html
作者
Echo Yu
发布于
2022年8月31日
许可协议