This is an automated email from the ASF dual-hosted git repository.
guozhang 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 8a2d00f KAFKA-6405: Fix incorrect comment in MetadataUpdater (#4361)
8a2d00f is described below
commit 8a2d00fc44eb48bf80fd2383178665986a73cdd8
Author: Guangxian <[email protected]>
AuthorDate: Thu Feb 8 09:44:40 2018 +0800
KAFKA-6405: Fix incorrect comment in MetadataUpdater (#4361)
* Fix incorrect comment in MetadataUpdater
* Fix comment for handleCompletedMetadataResponse
---
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
b/clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
index cb821d6..1267283 100644
--- a/clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
+++ b/clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
@@ -54,7 +54,7 @@ interface MetadataUpdater {
long maybeUpdate(long now);
/**
- * If `request` is a metadata request, handles it and return `true`.
Otherwise, returns `false`.
+ * Handle disconnections for metadata requests.
*
* This provides a mechanism for the `MetadataUpdater` implementation to
use the NetworkClient instance for its own
* requests with special handling for disconnections of such requests.
@@ -70,7 +70,7 @@ interface MetadataUpdater {
void handleAuthenticationFailure(AuthenticationException exception);
/**
- * If `request` is a metadata request, handles it and returns `true`.
Otherwise, returns `false`.
+ * Handle responses for metadata requests.
*
* This provides a mechanism for the `MetadataUpdater` implementation to
use the NetworkClient instance for its own
* requests with special handling for completed receives of such requests.
--
To stop receiving notification emails like this one, please contact
[email protected].
