From 94f1957f038856241398bc209c3adfadc9344592 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 21 Mar 2026 11:44:26 -0700 Subject: [PATCH] Dont use OffsetCommitRequest DEFAULT_RETENTION_TIME in coordinator --- 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 2d04529a4..3f834ccf4 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -696,7 +696,7 @@ def _send_offset_commit_request(self, offsets): self.group_id, generation.generation_id, generation.member_id, - OffsetCommitRequest[version].DEFAULT_RETENTION_TIME, + -1, # default retention time [( topic, [( partition,