This is an automated email from the ASF dual-hosted git repository.
AndrewJSchofield pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8ba75d04cb4 MINOR: Add generic fenced state error message (#22994)
8ba75d04cb4 is described below
commit 8ba75d04cb48f01ec0c958a7e5675b0c19a98eb5
Author: Federico Valeri <[email protected]>
AuthorDate: Thu Jul 30 16:25:12 2026 +0200
MINOR: Add generic fenced state error message (#22994)
This error may be used by other coordinators adopting the Coordinator
Runtime framework, so it would be good to make the error message more
generic.
Reviewers: Andrew Schofield <[email protected]>, Luke Chen
<[email protected]>, Ken Huang <[email protected]>
Signed-off-by: Federico Valeri <[email protected]>
---
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
index 15ac7765a29..49b67b738d5 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
@@ -411,7 +411,7 @@ public enum Errors {
INVALID_RECORD_STATE(121, "The record state is invalid. The
acknowledgement of delivery could not be completed.",
InvalidRecordStateException::new),
SHARE_SESSION_NOT_FOUND(122, "The share session was not found.",
ShareSessionNotFoundException::new),
INVALID_SHARE_SESSION_EPOCH(123, "The share session epoch is invalid.",
InvalidShareSessionEpochException::new),
- FENCED_STATE_EPOCH(124, "The share coordinator rejected the request
because the share-group state epoch did not match.",
FencedStateEpochException::new),
+ FENCED_STATE_EPOCH(124, "The coordinator rejected the request because the
state epoch did not match.", FencedStateEpochException::new),
INVALID_VOTER_KEY(125, "The voter key doesn't match the receiving
replica's key.", InvalidVoterKeyException::new),
DUPLICATE_VOTER(126, "The voter is already part of the set of voters.",
DuplicateVoterException::new),
VOTER_NOT_FOUND(127, "The voter is not part of the set of voters.",
VoterNotFoundException::new),
