[GitHub] [kafka] guozhangwang commented on a change in pull request #10232: KAFKA-12352: Make sure all rejoin group and reset state has a reason

2021-03-12 Thread GitBox
guozhangwang commented on a change in pull request #10232: URL: https://github.com/apache/kafka/pull/10232#discussion_r593515777 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -775,8 +776,6 @@ public void handle(S

[GitHub] [kafka] guozhangwang commented on a change in pull request #10232: KAFKA-12352: Make sure all rejoin group and reset state has a reason

2021-03-12 Thread GitBox
guozhangwang commented on a change in pull request #10232: URL: https://github.com/apache/kafka/pull/10232#discussion_r593504141 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -775,8 +776,6 @@ public void handle(S

[GitHub] [kafka] guozhangwang commented on a change in pull request #10232: KAFKA-12352: Make sure all rejoin group and reset state has a reason

2021-03-05 Thread GitBox
guozhangwang commented on a change in pull request #10232: URL: https://github.com/apache/kafka/pull/10232#discussion_r588847540 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -802,8 +801,10 @@ public void handle(

[GitHub] [kafka] guozhangwang commented on a change in pull request #10232: KAFKA-12352: Make sure all rejoin group and reset state has a reason

2021-03-05 Thread GitBox
guozhangwang commented on a change in pull request #10232: URL: https://github.com/apache/kafka/pull/10232#discussion_r588842618 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -775,8 +776,6 @@ public void handle(S

[GitHub] [kafka] guozhangwang commented on a change in pull request #10232: KAFKA-12352: Make sure all rejoin group and reset state has a reason

2021-02-28 Thread GitBox
guozhangwang commented on a change in pull request #10232: URL: https://github.com/apache/kafka/pull/10232#discussion_r584479103 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -961,29 +962,34 @@ protected synchron