Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Commit

Permalink
add readme note about assignment strategies
Browse files Browse the repository at this point in the history
  • Loading branch information
emmettbutler committed Dec 19, 2017
1 parent 5f3c276 commit 8b07807
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,10 @@ this, you can use the `BalancedConsumer`.
You can have as many `BalancedConsumer` instances consuming a topic as that
topic has partitions. If they are all connected to the same zookeeper instance,
they will communicate with it to automatically balance the partitions between
themselves.
themselves. The partition assignment strategy used by the `BalancedConsumer` is
the "range" strategy by default. The strategy is switchable via the `membership_protocol`
keyword argument, and can be either an object exposed by `pykafka.membershipprotocol` or
a custom instance of `pykafka.membershipprotocol.GroupMembershipProtocol`.

You can also use the Kafka 0.9 Group Membership API with the ``managed``
keyword argument on ``get_balanced_consumer``.
Expand Down

0 comments on commit 8b07807

Please sign in to comment.