From f0c1e6786fb75d24b5073928d73f6513d20ba3f3 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Wed, 18 Mar 2026 16:31:00 -0700
Subject: [PATCH] Add DEFAULT_GENERATION_ID and UNKNOWN_MEMBER_ID to
 kafka.protocol.new.consumer.group

---
 kafka/protocol/new/consumer/group.py         | 4 ++++
 test/protocol/new/consumer/test_new_group.py | 9 +++++++++
 2 files changed, 13 insertions(+)

diff --git a/kafka/protocol/new/consumer/group.py b/kafka/protocol/new/consumer/group.py
index 59df82dee..67b44a7b8 100644
--- a/kafka/protocol/new/consumer/group.py
+++ b/kafka/protocol/new/consumer/group.py
@@ -1,6 +1,9 @@
 from ..api_message import ApiMessage
 
 
+DEFAULT_GENERATION_ID = -1
+UNKNOWN_MEMBER_ID = ''
+
 class JoinGroupRequest(ApiMessage): pass
 class JoinGroupResponse(ApiMessage): pass
 
@@ -21,6 +24,7 @@ class OffsetCommitResponse(ApiMessage): pass
 
 
 __all__ = [
+    'DEFAULT_GENERATION_ID', 'UNKNOWN_MEMBER_ID',
     'JoinGroupRequest', 'JoinGroupResponse',
     'SyncGroupRequest', 'SyncGroupResponse',
     'LeaveGroupRequest', 'LeaveGroupResponse',
diff --git a/test/protocol/new/consumer/test_new_group.py b/test/protocol/new/consumer/test_new_group.py
index e4aa909bb..44bdd8dda 100644
--- a/test/protocol/new/consumer/test_new_group.py
+++ b/test/protocol/new/consumer/test_new_group.py
@@ -2,6 +2,7 @@
 
 from kafka.protocol.new.metadata import FindCoordinatorRequest, FindCoordinatorResponse
 from kafka.protocol.new.consumer import (
+    DEFAULT_GENERATION_ID, UNKNOWN_MEMBER_ID,
     JoinGroupRequest, JoinGroupResponse,
     SyncGroupRequest, SyncGroupResponse,
     LeaveGroupRequest, LeaveGroupResponse,
@@ -331,3 +332,11 @@ def test_offset_commit_response_roundtrip(version):
     encoded = OffsetCommitResponse.encode(data, version=version)
     decoded = OffsetCommitResponse.decode(encoded, version=version)
     assert decoded == data
+
+
+def test_default_generation_id():
+    assert DEFAULT_GENERATION_ID == -1
+
+
+def test_unknown_member_id():
+    assert UNKNOWN_MEMBER_ID == ''