diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 25da9fe1b..52299c79e 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -66,7 +66,7 @@ def __init__(self, client, subscription, **configs): a commit request completes. assignors (list): List of objects to use to distribute partition ownership amongst consumer instances when group management is - used. Default: [RangePartitionAssignor, RoundRobinPartitionAssignor] + used. Default: [RangePartitionAssignor, RoundRobinPartitionAssignor, StickyPartitionAssignor] heartbeat_interval_ms (int): The expected time in milliseconds between heartbeats to the consumer coordinator when using Kafka's group management feature. Heartbeats are used to ensure