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

[chia7712]

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

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


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

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

    MINOR: Fix null exception in coordinator log (#10250)
    
    Reviewers: A. Sophie Blee-Goldman <sop...@confluent.io>, Chia-Ping Tsai 
<chia7...@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 3eb86db..2f0d6c8 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", future.exception());
                     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());