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