【Flink】Discard registration from TaskExecutor SplitFetcher received unexpected exception

阅读 33

2022-03-11

在这里插入图片描述

1.概述

FLink消费kafka 一个新的 group.id ,消费一个老 topic ,服务启动的时候,遇到了这个问题。

  1. Discard registration from TaskExecutor SplitFetcher
  2. SplitFetcher thread 0 received unexpected exception while polling the records
  3. NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

具体的错误如需

错误1

2022-03-03 19:40:32

精彩评论(0)

0 0 举报