什么是kafka.common.OffsetOutOfRangeException的意思

我正在尝试通过Apache Kafka加载数据并不断收到此错误:

kafka.common.OffsetOutOfRangeException:偏移量1003786超出了kafka.log.Log $ .findRange(Log.scala:46)的范围,位于kafka.log.Log.read(读取:264),位于kafka.server.KafkaRequestHandlers. kafka $ server $ KafkaRequestHandlers $$ readMessageSet(KafkaRequestHandlers.scala:112)at kafka.server.KafkaRequestHandlers $$ anonfun $ 2.apply(KafkaRequestHandlers.scala:101)at kafka.server.KafkaRequestHandlers $$ anonfun $ 2.apply(KafkaRequestHandlers.scala :100)scala.collection.TraversableLike $$ anonfun $ map $ 1.apply(TraversableLike.scala:206)at scala.collection.TraversableLike $$ anonfun $ map $ 1.apply(TraversableLike.scala:206)at scala.collection.在scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)在scala.collection.TraversableLike $ class.map(TraversableLike.scala:206)在scala.collection:IndexedSeqOptimized $ class.foreach(34 IndexedSeqOptimized.scala) .mutable.ArrayOps.map(ArrayOps.scala:34)位于kafka.server.K的kafka.server.KafkaRequestHandlers.handleMultiFetchRequest(KafkaRequestHandlers.scala:100)afkaRequestHandlers $$ anonfun $ handlerFor $ 3.apply(KafkaRequestHandlers.scala:40)在kafka.server.KafkaRequestHandlers $$ anonfun $ handlerFor $ 3.apply(KafkaRequestHandlers.scala:40)在kafka.network.Processor.handle(SocketServer.scala: 296)at kafka.network.Processor.read(SocketServer.scala:319)at kafka.network.Processor.run(SocketServer.scala:214)at java.lang.Thread.run(Thread.java:724)

这个例外意味着什么以及如何解决它？

OffsetOutOfRangeException通常表示客户端已请求服务器上不再可用的范围.
这可能发生在主题日志不再存在的基础上,基于Kafka设置中的保留策略.
如果您正在使用SimpleConsumer,则需要在代码中处理OffsetOutOfRange异常.理想情况下,您的使用者应发出OffsetRequest以获取服务器上当前可用的最新/最早的偏移量,然后在FetchRequest中使用它(作为参数)