diff options
Diffstat (limited to 'kafka/coordinator/base.py')
| -rw-r--r-- | kafka/coordinator/base.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 66d7e6c..d6ffc3a 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -43,10 +43,10 @@ class BaseCoordinator(object): leader and begins processing. To leverage this protocol, an implementation must define the format of - metadata provided by each member for group registration in group_protocols() - and the format of the state assignment provided by the leader in - _perform_assignment() and which becomes available to members in - _on_join_complete(). + metadata provided by each member for group registration in + :meth:`.group_protocols` and the format of the state assignment provided by + the leader in :meth:`._perform_assignment` and which becomes available to + members in :meth:`._on_join_complete`. """ DEFAULT_CONFIG = { @@ -277,7 +277,7 @@ class BaseCoordinator(object): """Join the group and return the assignment for the next generation. This function handles both JoinGroup and SyncGroup, delegating to - _perform_assignment() if elected leader by the coordinator. + :meth:`._perform_assignment` if elected leader by the coordinator. Returns: Future: resolves to the encoded-bytes assignment returned from the |