(kafka) branch trunk updated: MINOR: log fix in SnapshottableCoordinator (#17726)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chia7712 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 65ae070e12f MINOR: log fix in SnapshottableCoordinator (#17726)
65ae070e12f is described below

commit 65ae070e12f8b38b75b1c6127fe457401192d386
Author: Jeff Kim <ki...@gmail.com>
AuthorDate: Sat Nov 9 01:00:41 2024 -0500

    MINOR: log fix in SnapshottableCoordinator (#17726)
    
    Reviewers: donaldzhu-cc, Chia-Ping Tsai <ch...@gmail.com>
---
 .../kafka/coordinator/common/runtime/SnapshottableCoordinator.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
index 9c3b87e7ad5..3aa622cc98b 100644
--- a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
+++ b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
@@ -165,7 +165,7 @@ public class SnapshottableCoordinator<S extends CoordinatorShard<U>, U> implemen
 
         if (offset > lastWrittenOffset) {
             throw new IllegalStateException("New committed offset " + offset + " of " + tp +
-                "must be less than or equal to " + lastWrittenOffset + ".");
+                " must be less than or equal to " + lastWrittenOffset + ".");
         }
 
         lastCommittedOffset = offset;