added support incremental rebalance in one session

Signed-off-by: Sergey Belyakov <[email protected]>
IBM · Aug 14, 2024 · b4beb63 · b4beb63
1 parent 7104aa7
commit b4beb63
Show file tree

Hide file tree

Showing 3 changed files with 540 additions and 35 deletions.
diff --git a/config.go b/config.go
@@ -304,6 +304,8 @@ type Config struct {
 				Interval time.Duration
 			}
 			Rebalance struct {
+				// IsIncremental to allow don't stopping the rebalance process when a new member joins the group.
+				IsIncremental bool
 				// Strategy for allocating topic partitions to members.
 				// Deprecated: Strategy exists for historical compatibility
 				// and should not be used. Please use GroupStrategies.