delta/python-packages/kafka-python.git/kafka/coordinator, branch idle_sleep

KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync

2016-01-10T20:06:04+00:00

ConsumerCoordinator cleanups

2016-01-10T16:57:52+00:00

  - default assignors to RoundRobinPartitionAssignor
  - check offsets types in commit_offsets_* methods
  - succeed future in _send_offset_commit_request when no offsets
  - raise exception if no subscribed topics in group_protocols()
  - fix _subscription typo in metadata listener callbacks
  - short circuit if no partitions passed to fetch_committed_offsets
  - line-wrap comments
  - return future from commit_offsets_async
  - return future value from commit_offsets_sync
  - fix self._failed_request callback partial args
  - comment out metrics class for now

Move ConsumerProtocol definition to kafka.coordinator.protocol

2016-01-10T08:25:12+00:00

Fix future redefine bug in client.poll

2016-01-04T08:18:58+00:00

Drop unused method from ConsumerCoordinator

2016-01-04T00:10:40+00:00

Check api_version in ConsumerCoordinator

2016-01-04T00:03:30+00:00

  - Full group support in 0.9
  - Kafka-storage offsets w/ GroupCoordinator in 0.8.2
  - Zookeeper-storage offsets in 0.8.1
  - Assign all partitions locally if < 0.9

Use python3 compatible next() in roundrobin assignor

2016-01-02T06:49:34+00:00

Fixup heartbeat config assertion

2015-12-31T19:20:01+00:00

Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinator

2015-12-31T00:18:26+00:00

Prefer assert or more-specific error to IllegalState / IllegalArgument

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