[ https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730360#comment-17730360 ]
YaYun Wang commented on KAFKA-15074: ------------------------------------ *Here is my code:* @KafkaListener( topics = "myTopic", containerFactory = "myContainerFactory") public void consume(ConsumerRecord<String, String> consumerRecord) throws ExecutionException, InterruptedException { String recordValue = consumerRecord.value(); // do something with recordValue } > offset out of range for partition xxx, resetting offset > ------------------------------------------------------- > > Key: KAFKA-15074 > URL: https://issues.apache.org/jira/browse/KAFKA-15074 > Project: Kafka > Issue Type: Bug > Components: clients, consumer > Affects Versions: 3.3.2 > Reporter: YaYun Wang > Priority: Major > > I ??got Fetch position FetchPosition{offset=42574305, > offsetEpoch=Optional[2214], > currentLeader=LeaderAndEpoch{leader=Optional[host:port (id: 2 rack: > cn-north-1d)], epoch=2214}} is out of range for partition > vcc.hdmap.tile.delivery-4, resetting offset ?? > when i consumer kafka through @KafkaListener. > > -- This message was sent by Atlassian Jira (v8.20.10#820010)