flink 消费kafka的数据出现异常排查

1、错误日志如下；{"timestamp": "2022-01-27 17:07:55.680","host": "gd12-k8s-noah-vrc-prod001-node-s0384","message": "2022-01-27 17:07:49,041 INFOorg.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSess

wppwpp1

2984人浏览 · 2022-01-29 12:27:42

wppwpp1 · 2022-01-29 12:27:42 发布

1、错误日志如下；

{
  "timestamp": "2022-01-27 17:07:55.680",
  "host": "gd12-k8s-noah-vrc-prod001-node-s0384",
  "message": "2022-01-27 17:07:49,041 INFO  org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-kafka_2_tendis_detail_gid-15, groupId=kafka_2_tendis_detail_gid] Node 4 was unable to process the fetch request with (sessionId=1381439767, epoch=1657025): FETCH_SESSION_ID_NOT_FOUND.",
  "path": "/apps/logs/log_receiver/ai-noah.vip.vip.com/tm-ord2tendis-all-flink-78988-gg7o5n-75f8448cc8-jbkcx/flink/dataeye/tm-ord2tendis-all.flink-78988.dataeye/ord2tendis-all.flink.bigdata.vip.com/task.log",
  "logLevel": "",
  "eventName": "",
  "logid": "8892444480957757",
  "threadName": ""
}