kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [2/2] kafka git commit: set the rejoinNeeded in listener's onSuccess
Date Thu, 01 Jun 2017 20:33:05 GMT
set the rejoinNeeded in listener's onSuccess


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a4a3e1e5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a4a3e1e5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a4a3e1e5

Branch: refs/heads/0.11.0
Commit: a4a3e1e5d6bb75ad0abc555ba207ce48307edfa8
Parents: 0e36cf7
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Thu Jun 1 13:31:25 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Jun 1 13:32:58 2017 -0700

----------------------------------------------------------------------
 .../kafka/clients/consumer/internals/AbstractCoordinator.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a4a3e1e5/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
----------------------------------------------------------------------
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 e380bae..aa3807e 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
@@ -398,6 +398,7 @@ public abstract class AbstractCoordinator implements Closeable {
                     synchronized (AbstractCoordinator.this) {
                         log.info("Successfully joined group {} with generation {}", groupId,
generation.generationId);
                         state = MemberState.STABLE;
+                        rejoinNeeded = false;
 
                         if (heartbeatThread != null)
                             heartbeatThread.enable();
@@ -536,7 +537,6 @@ public abstract class AbstractCoordinator implements Closeable {
             if (error == Errors.NONE) {
                 sensors.syncLatency.record(response.requestLatencyMs());
                 future.complete(syncResponse.memberAssignment());
-                AbstractCoordinator.this.rejoinNeeded = false;
             } else {
                 requestRejoin();
 


Mime
View raw message