[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1322027402 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AssignorSelection.java: ## @@ -0,0 +1,102 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1322000996 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,212 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1322000996 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,212 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1322000996 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,212 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321733445 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321783061 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321783061 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321737185 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321737185 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321733445 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321621168 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321621168 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321577970 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321537135 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManager.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1321522306 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1320184381 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManager.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1320145450 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1320085005 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AssignorSelection.java: ## @@ -0,0 +1,102 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1320013571 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319972998 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319972998 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319972998 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319944582 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319927882 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManager.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319899063 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319876418 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319075024 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319075024 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1319005335 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1318665973 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1318655049 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1318645607 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

[GitHub] [kafka] lianetm commented on a diff in pull request #14323: KAFKA-15275 - Client state machine basic components, states and initial transitions

lianetm commented on code in PR #14323: URL: https://github.com/apache/kafka/pull/14323#discussion_r1318635008 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AssignorSelection.java: ## @@ -0,0 +1,102 @@ +/* + * Licensed to the Apache Software Foundation (AS