You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2021/03/03 04:58:57 UTC
[kafka] branch 2.7 updated: MINOR: Fix null exception in
coordinator log (#10250)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.7 by this push:
new 51d2609 MINOR: Fix null exception in coordinator log (#10250)
51d2609 is described below
commit 51d2609052276b3388f604747ed188a8840f2078
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 32db599..f9e5fc0 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());