Skip to content

Commit ada6a47

Browse files
committed
fix(proto): skip empty UserData during plan
This avoids a subsequent decoder failure where UserData is empty Signed-off-by: Dominic Evans <[email protected]>
1 parent ce313d9 commit ada6a47

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

balance_strategy.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -967,6 +967,9 @@ func prepopulateCurrentAssignments(members map[string]ConsumerGroupMemberMetadat
967967
// for each partition we create a sorted map of its consumers by generation
968968
sortedPartitionConsumersByGeneration := make(map[topicPartitionAssignment]map[int]string)
969969
for memberID, meta := range members {
970+
if len(meta.UserData) == 0 {
971+
continue
972+
}
970973
consumerUserData, err := deserializeTopicPartitionAssignment(meta.UserData)
971974
if err != nil {
972975
return nil, nil, err

0 commit comments

Comments
 (0)