FrankChen021 commented on issue #14344:
URL: https://github.com/apache/druid/issues/14344#issuecomment-2969414401
```
2025-06-13T06:28:52,089 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
OffsetOutOfRangeException with message [Fetch position
FetchPosition{offset=11018217440, offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[10.169.27.25:9093 (id: 1002 rack:
ap-sg-1-general-b)], epoch=84}} is out of range for partition de._txn-1]
2025-06-13T06:28:52,089 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
Retrying in 30000ms
2025-06-13T06:29:22,093 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
OffsetOutOfRangeException with message [Fetch position
FetchPosition{offset=11004815888, offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[10.169.27.24:9093 (id: 1001 rack:
ap-sg-1-general-b)], epoch=89}} is out of range for partition de._txn-0]
2025-06-13T06:29:22,093 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
Retrying in 30000ms
2025-06-13T06:29:52,094 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
OffsetOutOfRangeException with message [Fetch position
FetchPosition{offset=11018217440, offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[10.169.27.25:9093 (id: 1002 rack:
ap-sg-1-general-b)], epoch=84}} is out of range for partition de._txn-1]
2025-06-13T06:29:52,094 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
Retrying in 30000ms
2025-06-13T06:30:22,100 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
OffsetOutOfRangeException with message [Fetch position
FetchPosition{offset=11004815888, offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[10.169.27.24:9093 (id: 1001 rack:
ap-sg-1-general-b)], epoch=89}} is out of range for partition de._txn-0]
2025-06-13T06:30:22,100 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
Retrying in 30000ms
2025-06-13T06:30:52,101 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
OffsetOutOfRangeException with message [Fetch position
FetchPosition{offset=11018217440, offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[10.169.27.25:9093 (id: 1002 rack:
ap-sg-1-general-b)], epoch=84}} is out of range for partition de._txn-1]
2025-06-13T06:30:52,101 WARN [task-runner-0-priority-0]
org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner -
Retrying in 30000ms
```
reproduced in one cluster. above messages were printed periodically.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
