Skip to content

Commit 522a211

Browse files
authored
Fixup sticky assignor docstrings (#2762)
1 parent 40ef80a commit 522a211

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

kafka/coordinator/assignors/sticky/sticky_assignor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -591,7 +591,7 @@ def assign(cls, cluster, members):
591591
members (dict of {member_id: MemberMetadata}): decoded metadata for each member in the group.
592592
593593
Returns:
594-
dict: {member_id: MemberAssignment}
594+
dict: {member_id: ConsumerProtocolAssignment}
595595
"""
596596
members_metadata = {}
597597
for consumer, member_metadata in members.items():
@@ -619,7 +619,7 @@ def parse_member_metadata(cls, metadata):
619619
there is no need to support backward compatibility with V0.
620620
621621
Arguments:
622-
metadata (MemberMetadata): decoded metadata for a member of the group.
622+
metadata (ConsumerProtocolSubscription): decoded subscription for a member of the group.
623623
624624
Returns:
625625
parsed metadata (StickyAssignorMemberMetadataV1)

0 commit comments

Comments
 (0)