KafkaConsumer调用seek()方法报错

Posted 敲代码的小小酥

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了KafkaConsumer调用seek()方法报错相关的知识,希望对你有一定的参考价值。

在开发中收到调用seek方法指定偏移量时,报了如下错误:

java.lang.IllegalStateException: No current assignment for partition xxx

报错的意思是该分区没有你指定的那个偏移量,但是在Kafka可视化工具上看,明明有那个偏移量,为何会报这个错呢。
原来,subscribe()和 assign()是懒惰的-因此,还需要在您可以使用 seek()之前,先对 poll()进行"虚拟调用"。

以上是关于KafkaConsumer调用seek()方法报错的主要内容,如果未能解决你的问题,请参考以下文章

lsnrctl启动报错,Linux Error: 29: Illegal seek

lsnrctl启动报错,Linux Error: 29: Illegal seek

操作错误: lsnrctl启动报错(lsnrctl start),Linux Error: 29: Illegal seek

操作错误: lsnrctl启动报错(lsnrctl start),Linux Error: 29: Illegal seek

day10函数与模块

Kafka Consumer多线程实例续篇