flink-cdc接mysql/mongo 然后写入mq(ververica-connector-mq),为什么经常日志会这样?info2023-12-21 01:01:44,599 [MQClientFactoryScheduledThread] INFO RocketmqClient [] – send heart beat to broker[mqtrace4hz-23 0 100.100.110.30:8080] failed
以下为热心网友提供的参考意见
这是个 info日志,无需担心,主要关注 Flink 任务 Failover、rps 、checkpoint等是否有影响
您发的这段日志是来自RocketmqClient的信息,它表明心跳发送给[mqtrace4hz-23 0 100.100.110.30:8080]这个代理服务器失败了。通过发送心跳,客户端可以告知代理服务器它的状态和可用性。此回答整理自钉群“实时计算Flink产品交流群”