From ad51281ffa94841ef9def93cdadfe09b59f60788 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 20 Mar 2026 18:25:42 -0700 Subject: [PATCH] Fix coordinator docs re default assignors (StickyPartitionAssignor) --- kafka/coordinator/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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