[kafka] branch 2.6 updated: MINOR: Fix null exception in coordinator log (#10250)

[ch...@apache.org]

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

chia7712 pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.6 by this push:
     new f80b935  MINOR: Fix null exception in coordinator log (#10250)
f80b935 is described below

commit f80b9359c28480b2fe6f6a1610f550cd95b4ca9b
Author: dengziming <sw...@163.com>
AuthorDate: Wed Mar 3 12:38:06 2021 +0800

    MINOR: Fix null exception in coordinator log (#10250)
    
    Reviewers: A. Sophie Blee-Goldman <so...@confluent.io>, Chia-Ping Tsai <ch...@gmail.com>
---
 .../apache/kafka/clients/consumer/internals/AbstractCoordinator.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 f8120e7..0138a32 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
@@ -256,8 +256,8 @@ public abstract class AbstractCoordinator implements Closeable {
                     log.debug("Coordinator discovery failed, refreshing metadata");
                     client.awaitMetadataUpdate(timer);
                 } else {
-                    log.info("FindCoordinator request hit fatal exception", fatalException);
                     fatalException = future.exception();
+                    log.info("FindCoordinator request hit fatal exception", fatalException);
                 }
             } else if (coordinator != null && client.isUnavailable(coordinator)) {
                 // we found the coordinator, but the connection has failed, so mark
@@ -267,7 +267,7 @@ public abstract class AbstractCoordinator implements Closeable {
             }
 
             clearFindCoordinatorFuture();
-            if (fatalException !=  null)
+            if (fatalException != null)
                 throw fatalException;
         } while (coordinatorUnknown() && timer.notExpired());