From 3286079dcaf0050607da969da04da63e24aeccdf Mon Sep 17 00:00:00 2001 From: David Jacot Date: Tue, 7 Jan 2025 10:31:40 +0100 Subject: [PATCH] MINOR: Fix typo in CommitRequestManager --- .../kafka/clients/consumer/internals/CommitRequestManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java index 41522889768b9..4f0deef5bf890 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java @@ -477,7 +477,7 @@ private void commitSyncWithRetries(OffsetCommitRequestState requestAttempt, private Throwable commitSyncExceptionForError(Throwable error) { if (error instanceof StaleMemberEpochException) { - return new CommitFailedException("OffsetCommit failed with stale member epoch." + return new CommitFailedException("OffsetCommit failed with stale member epoch. " + Errors.STALE_MEMBER_EPOCH.message()); } return error;