delta/python-packages/kafka-python.git/kafka/consumer/subscription_state.py, branch null_logger github.com: mumrah/kafka-python.git KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync 2016-01-10T20:06:04+00:00 Dana Powers dana.powers@rd.io 2016-01-10T00:52:01+00:00 9837927c70abd3e032a9aefbd2990a7605276670 






Add error checking to mark_for_reassignment
2016-01-10T16:57:52+00:00

Dana Powers
dana.powers@rd.io

2016-01-10T08:34:23+00:00

35ed2e75dab2ba44b57f4e7183ebc020f3121124












Prefer assert or more-specific error to IllegalState / IllegalArgument
2015-12-31T00:16:13+00:00

Dana Powers
dana.powers@rd.io

2015-12-31T00:16:13+00:00

422050f952344e4796725d88db55a983bae4e1ee












More Docstring Improvements
2015-12-30T20:51:34+00:00

Dana Powers
dana.powers@rd.io

2015-12-30T20:51:34+00:00

e093ffefaecb59c26f2e480214f72a03ba5a49fc












Log as INFO: group join, leader election, partition assignments
2015-12-30T01:16:04+00:00

Dana Powers
dana.powers@rd.io

2015-12-30T01:04:24+00:00

ab1578444c79703610228531beef259478614338












Improve various docstrings
2015-12-30T01:05:08+00:00

Dana Powers
dana.powers@rd.io

2015-12-30T01:01:41+00:00

2a2733d4fc725f04461a6c4d0ca0fc253f99caeb












Make add_assigned_partition private(ish) in SubscriptionState
2015-12-30T01:05:07+00:00

Dana Powers
dana.powers@rd.io

2015-12-30T00:58:38+00:00

aa35c4e424424687b3ff4a89a10e51d96f365279












Define ConsumerRebalanceListener abstract class
2015-12-28T22:57:54+00:00

Dana Powers
dana.powers@rd.io

2015-12-28T22:54:50+00:00

9820c5d55398bdb49ffbcd0e6a997bde9f8891fe












New class SubscriptionState, based on upstream Java client
2015-12-28T22:57:54+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T17:14:57+00:00

b643ba1a1ed7838625012e6f75a1ed9b35ffd022