Skip to content

Commit 337d231

Browse files
committed
StickAssignor exception handling fixup (and comment re members field)
1 parent 94a89e7 commit 337d231

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

kafka/coordinator/assignors/sticky/sticky_assignor.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ class StickyAssignorUserDataV1(Struct):
6666

6767
class StickyAssignmentExecutor:
6868
def __init__(self, cluster, members):
69+
# a mapping of member_id => StickyAssignorMemberMetadataV1
6970
self.members = members
7071
# a mapping between consumers and their assigned partitions that is updated during assignment procedure
7172
self.current_assignment = defaultdict(list)
@@ -630,9 +631,9 @@ def parse_member_metadata(cls, metadata):
630631

631632
try:
632633
decoded_user_data = StickyAssignorUserDataV1.decode(user_data)
633-
except Exception as e:
634+
except Exception:
634635
# ignore the consumer's previous assignment if it cannot be parsed
635-
log.error("Could not parse member data", e) # pylint: disable=logging-too-many-args
636+
log.exception("Could not parse member data")
636637
return StickyAssignorMemberMetadataV1(
637638
partitions=[], generation=cls.DEFAULT_GENERATION_ID, subscription=metadata.topics
638639
)

0 commit comments

Comments
 (0)