diff --git a/kafka/coordinator/assignors/sticky/sticky_assignor.py b/kafka/coordinator/assignors/sticky/sticky_assignor.py index 5e29d5894..bb6c10fe2 100644 --- a/kafka/coordinator/assignors/sticky/sticky_assignor.py +++ b/kafka/coordinator/assignors/sticky/sticky_assignor.py @@ -591,7 +591,7 @@ def assign(cls, cluster, members): members (dict of {member_id: MemberMetadata}): decoded metadata for each member in the group. Returns: - dict: {member_id: MemberAssignment} + dict: {member_id: ConsumerProtocolAssignment} """ members_metadata = {} for consumer, member_metadata in members.items(): @@ -619,7 +619,7 @@ def parse_member_metadata(cls, metadata): there is no need to support backward compatibility with V0. Arguments: - metadata (MemberMetadata): decoded metadata for a member of the group. + metadata (ConsumerProtocolSubscription): decoded subscription for a member of the group. Returns: parsed metadata (StickyAssignorMemberMetadataV1)