[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-08 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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 producer publish 100W data 
to partition 4 in several minutes and consumer consume data through 
@KafkaListener , just one consumer exists.

 

 

  was:
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 producer publish 100W data 
to partition 4 in several minutes and consumer consume data through 
@KafkaListener , and one consumer consume the data from the partition.

 

 


> 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 producer publish 100W 
> data to partition 4 in several minutes and consumer consume data through 
> @KafkaListener , just one consumer exists.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-08 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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 producer publish 100W data 
to partition 4 in several minutes and consumer consume data through 
@KafkaListener , and one consumer consume the data from the partition.

 

 

  was:
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 in that case producer publish 100W data to partition 4 in 
several minutes, and one consumer consume the data from the partition.

 

 


> 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 producer publish 100W 
> data to partition 4 in several minutes and consumer consume data through 
> @KafkaListener , and one consumer consume the data from the partition.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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 in that case producer publish 100W data to partition 4 in 
several minutes, and one consumer consume the data from the partition.

 

 

  was:
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 in that case producer publish 100W data to partition 4 in one 
minute, and one consumer consume the data from the partition.

 

 


> 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 in that case producer publish 100W data to partition 4 in 
> several minutes, and one consumer consume the data from the partition.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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 in that case producer publish 100W data to partition 4 in one 
minute, and one consumer consume the data from the partition.

 

 

  was:
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 in that case producer publish 100W 
data to partition 4 in one minute, and one consumer consume the data from the 
partition.

 

 


> 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 in that case producer publish 100W data to partition 4 in one 
> minute, and one consumer consume the data from the partition.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Comment Edited] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


[ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730365#comment-17730365
 ] 

YaYun Wang edited comment on KAFKA-15074 at 6/8/23 3:30 AM:


*And here is the debug logs of kafka-client:*

2023-06-06 09:12:59.576+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.i.ConsumerCoordinator - [handle] [Consumer 
clientId=consumer-group-1, groupId=group] Committed offset 42574009 for 
partition myTopic-4
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-1 at position FetchPosition{offset=2776251, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 2 rack: 
cn-north-1d)], epoch=}} to node host:9093 (id: 2 rack: cn-north-1d)
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-7 at position FetchPosition{offset=1678666, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 2 rack: 
cn-north-1d)], epoch=}} to node host:9093 (id: 2 rack: cn-north-1d)
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [sendFetches] [Consumer 
clientId=consumer-group-1, groupId=group] Sending READ_UNCOMMITTED 
IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), 
implied=(myTopic-1, myTopic-7), canUseTopicIds=True) to broker host:9093 (id: 2 
rack: cn-north-1d)
2023-06-06 09:12:59.963+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.i.ConsumerCoordinator - [handle] [Consumer 
clientId=consumer-group-1, groupId=group] Committed offset 42574109 for 
partition myTopic-4
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-8 at position FetchPosition{offset=2559637, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=2001}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-0 at position FetchPosition{offset=1678355, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=1996}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-3 at position FetchPosition{offset=2773458, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=2171}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-2 at position FetchPosition{offset=1677672, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=2001}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-5 at position FetchPosition{offset=1678870, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=1999}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1|#0-0-C-1] 
[traceId=] DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-6 at position FetchPosition{offset=1994802, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=1996}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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 in that case producer publish 100W 
data to partition 4 in one minute, and one consumer consume the data from the 
partition.

 

 

  was:
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.

 

 


> 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 in that case producer publish 
> 100W data to partition 4 in one minute, and one consumer consume the data 
> from the partition.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Commented] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


[ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730365#comment-17730365
 ] 

YaYun Wang commented on KAFKA-15074:


And here is my debug logs of kafka-client:

2023-06-06 09:12:59.576+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.i.ConsumerCoordinator - [handle] [Consumer 
clientId=consumer-group-1, groupId=group] Committed offset 42574009 for 
partition myTopic-4
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-1 at position FetchPosition\{offset=2776251, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 2 rack: 
cn-north-1d)], epoch=}} to node host:9093 (id: 2 rack: cn-north-1d)
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-7 at position FetchPosition\{offset=1678666, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 2 rack: 
cn-north-1d)], epoch=}} to node host:9093 (id: 2 rack: cn-north-1d)
2023-06-06 09:12:59.577+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [sendFetches] [Consumer 
clientId=consumer-group-1, groupId=group] Sending READ_UNCOMMITTED 
IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), 
implied=(myTopic-1, myTopic-7), canUseTopicIds=True) to broker host:9093 (id: 2 
rack: cn-north-1d)
2023-06-06 09:12:59.963+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.i.ConsumerCoordinator - [handle] [Consumer 
clientId=consumer-group-1, groupId=group] Committed offset 42574109 for 
partition myTopic-4
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-8 at position FetchPosition\{offset=2559637, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=2001}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-0 at position FetchPosition\{offset=1678355, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=1996}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-3 at position FetchPosition\{offset=2773458, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=2171}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-2 at position FetchPosition\{offset=1677672, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=2001}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-5 at position FetchPosition\{offset=1678870, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 0 rack: 
cn-north-1a)], epoch=1999}} to node host:9093 (id: 0 rack: cn-north-1a)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [prepareFetchRequests] [Consumer 
clientId=consumer-group-1, groupId=group] Added READ_UNCOMMITTED fetch request 
for partition myTopic-6 at position FetchPosition\{offset=1994802, 
offsetEpoch=Optional.empty, 
currentLeader=LeaderAndEpoch{leader=Optional[host:9093 (id: 1 rack: 
cn-north-1b)], epoch=1996}} to node host:9093 (id: 1 rack: cn-north-1b)
2023-06-06 09:12:59.964+ [istenerEndpointContainer#0-0-C-1] [traceId=] 
DEBUG o.a.k.c.c.internals.Fetcher - [sendFetches] [Consumer 
clientId=consumer-group-1, g

[jira] [Commented] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


[ 
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 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)

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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

 

 

  was:
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:

 

 


> 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)

[jira] [Updated] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

YaYun Wang updated KAFKA-15074:
---
Description: 
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.

 

 

  was:
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

 

 


> 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)

[jira] [Created] (KAFKA-15074) offset out of range for partition xxx, resetting offset

2023-06-07 Thread YaYun Wang (Jira) 
YaYun Wang created KAFKA-15074:
--

 Summary: 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


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)