FlinkDiscard registration from TaskExecutor SplitFetcher received unexpected exception

Posted 2022-03-05 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkDiscard registration from TaskExecutor SplitFetcher received unexpected exception相关的知识，希望对你有一定的参考价值。

1.概述

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

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

具体的错误如需

错误1

2022-03-03 19:40:

以上是关于FlinkDiscard registration from TaskExecutor SplitFetcher received unexpected exception的主要内容，如果未能解决你的问题，请参考以下文章