[
https://issues.apache.org/jira/browse/KAFKA-19251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivsundar R updated KAFKA-19251:
---------------------------------
Description:
All the flaky runs had this common error log.
{code:java}
ERROR [ShareCoordinator id=0 topic=__share_group_state partition=0] Request
state epoch smaller than last recorded.
(org.apache.kafka.coordinator.share.ShareCoordinatorShard:753) [2025-05-03
06:40:51,034] ERROR Unable to perform write state RPC for key
SharePartitionKey{groupId=group1,
topicIdPartition=FZVxXRYjTuCT7cdepYuz4w:null-0}: The share coordinator rejected
the request because the share-group state epoch did not match.
(org.apache.kafka.server.share.persister.PersisterStateManager$WriteStateHandler:752)
[2025-05-03 06:40:51,034] ERROR Failed to write the share group state for
share partition: group1-FZVxXRYjTuCT7cdepYuz4w:topic-0 due to exception
(kafka.server.share.SharePartition:2297)
org.apache.kafka.common.errors.FencedStateEpochException: Error in write state
RPC. The share coordinator rejected the request because the share-group state
epoch did not match. [2025-05-03 06:40:51,034] ERROR Failed to write state to
persister for the share partition: group1-FZVxXRYjTuCT7cdepYuz4w:topic-0
(kafka.server.share.SharePartition:2054)
org.apache.kafka.common.errors.FencedStateEpochException: Error in write state
RPC. The share coordinator rejected the request because the share-group state
epoch did not match.{code}
> Resolve the flaky test
> ShareConsumerTest.testMultipleConsumersInGroupConcurrentConsumption
> ------------------------------------------------------------------------------------------
>
> Key: KAFKA-19251
> URL: https://issues.apache.org/jira/browse/KAFKA-19251
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Chirag Wadhwa
> Assignee: Shivsundar R
> Priority: Major
>
> All the flaky runs had this common error log.
> {code:java}
> ERROR [ShareCoordinator id=0 topic=__share_group_state partition=0] Request
> state epoch smaller than last recorded.
> (org.apache.kafka.coordinator.share.ShareCoordinatorShard:753) [2025-05-03
> 06:40:51,034] ERROR Unable to perform write state RPC for key
> SharePartitionKey{groupId=group1,
> topicIdPartition=FZVxXRYjTuCT7cdepYuz4w:null-0}: The share coordinator
> rejected the request because the share-group state epoch did not match.
> (org.apache.kafka.server.share.persister.PersisterStateManager$WriteStateHandler:752)
> [2025-05-03 06:40:51,034] ERROR Failed to write the share group state for
> share partition: group1-FZVxXRYjTuCT7cdepYuz4w:topic-0 due to exception
> (kafka.server.share.SharePartition:2297)
> org.apache.kafka.common.errors.FencedStateEpochException: Error in write
> state RPC. The share coordinator rejected the request because the share-group
> state epoch did not match. [2025-05-03 06:40:51,034] ERROR Failed to write
> state to persister for the share partition:
> group1-FZVxXRYjTuCT7cdepYuz4w:topic-0
> (kafka.server.share.SharePartition:2054)
> org.apache.kafka.common.errors.FencedStateEpochException: Error in write
> state RPC. The share coordinator rejected the request because the share-group
> state epoch did not match.{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
