(kafka) branch trunk updated: MINOR: Remove extra "}" logged in KafkaStreams close (#15783)

[soarez]

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

soarez 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 e6b6b6c1c2c MINOR: Remove extra "}" logged in KafkaStreams close 
(#15783)
e6b6b6c1c2c is described below

commit e6b6b6c1c2c0fe958ff874a11211c5444a957a51
Author: Gyeongwon, Do <dct...@gmail.com>
AuthorDate: Tue Apr 23 17:45:36 2024 +0900

    MINOR: Remove extra "}" logged in KafkaStreams close (#15783)
    
    
    Reviewers: Igor Soarez <soa...@apple.com>
---
 streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java 
b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
index ff928e6ee81..89f8458b206 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -1543,7 +1543,7 @@ public class KafkaStreams implements AutoCloseable {
                 log.info("Streams client stopped to NOT_RUNNING completely");
                 return true;
             } else {
-                log.warn("Streams client cannot transition to {}} completely 
within the timeout",
+                log.warn("Streams client cannot transition to {} completely 
within the timeout",
                          state == State.PENDING_SHUTDOWN ? State.NOT_RUNNING : 
State.ERROR);
                 return false;
             }