Skip to content

Commit 397e607

Browse files
committed
Add null check for member assignment in rd_kafka_assign_ranges()
1 parent 2af6749 commit 397e607

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/rdkafka_range_assignor.c

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -373,6 +373,9 @@ static void rd_kafka_assign_ranges(
373373
member->rkgm_member_id,
374374
rktas->member_to_assigned_partitions);
375375

376+
if (member_assignment == NULL)
377+
continue;
378+
376379
maximum_assignable_to_consumer =
377380
rktas->num_partitions_per_consumer +
378381
(rktas->remaining_consumers_with_extra_partition > 0) -

0 commit comments

Comments
 (0)