[kafka] branch trunk updated: MINOR: Fix group coordinator is unavailable log (#12335)

[dajac]

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

dajac 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 cf9c3a2eca MINOR: Fix group coordinator is unavailable log (#12335)
cf9c3a2eca is described below

commit cf9c3a2ecaf0b6abf00194334157a1e94ff9f618
Author: David Jacot <dja...@confluent.io>
AuthorDate: Fri Jun 24 11:48:09 2022 +0200

    MINOR: Fix group coordinator is unavailable log (#12335)
    
    Reviewers: Kvicii <42023367+kvi...@users.noreply.github.com>, Luke Chen 
<show...@gmail.com>
---
 .../apache/kafka/clients/consumer/internals/AbstractCoordinator.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
index 2614259e38..fa80727d5a 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
@@ -946,7 +946,7 @@ public abstract class AbstractCoordinator implements 
Closeable {
 
     protected synchronized void markCoordinatorUnknown(boolean isDisconnected, 
String cause) {
         if (this.coordinator != null) {
-            log.info("Group coordinator {} is unavailable or invalid due to 
cause: {}."
+            log.info("Group coordinator {} is unavailable or invalid due to 
cause: {}. "
                     + "isDisconnected: {}. Rediscovery will be attempted.", 
this.coordinator,
                     cause, isDisconnected);
             Node oldCoordinator = this.coordinator;