Skip to content

Commit 51bef58

Browse files
authored
Fix coordinator docs re default assignors (StickyPartitionAssignor) (#2757)
1 parent eb588c8 commit 51bef58

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

kafka/coordinator/consumer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ def __init__(self, client, subscription, **configs):
6666
a commit request completes.
6767
assignors (list): List of objects to use to distribute partition
6868
ownership amongst consumer instances when group management is
69-
used. Default: [RangePartitionAssignor, RoundRobinPartitionAssignor]
69+
used. Default: [RangePartitionAssignor, RoundRobinPartitionAssignor, StickyPartitionAssignor]
7070
heartbeat_interval_ms (int): The expected time in milliseconds
7171
between heartbeats to the consumer coordinator when using
7272
Kafka's group management feature. Heartbeats are used to ensure

0 commit comments

Comments
 (0)