delta/python-packages/kafka-python.git/kafka/coordinator, branch iterator_timeout github.com: mumrah/kafka-python.git Ok to sleep in blocking poll for metadata update 2016-01-26T00:31:37+00:00 Dana Powers dana.powers@rd.io 2016-01-26T00:01:53+00:00 a154d0471c9181a6a6461466140e881018df4b8b 






Disable offset commits and auto-partition-assignment when group_id is None
2016-01-25T02:38:26+00:00

Dana Powers
dana.powers@rd.io

2016-01-25T00:22:14+00:00

2a1970138c233e1ebaa58b6db670b2ed0f8d8551












Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors
2016-01-24T21:25:28+00:00

Dana Powers
dana.powers@rd.io

2016-01-24T21:23:26+00:00

48e96822b3ec4f897438a2d1cdb735f51648cb48












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












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

Dana Powers
dana.powers@rd.io

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

bbd6444e85a3062224a977f1033da3f393110b87

  - 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





  - 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

Dana Powers
dana.powers@rd.io

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

b7104957f7294d3cb0e47d47ff1b6710acf5653e












Fix future redefine bug in client.poll
2016-01-04T08:18:58+00:00

Dana Powers
dana.powers@rd.io

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

16c834119b6113450a59a05ce627669ba5752f37












Drop unused method from ConsumerCoordinator
2016-01-04T00:10:40+00:00

Dana Powers
dana.powers@rd.io

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

abdbc6ca2785a5646ee9dccf4f5ccf700da5f648












Check api_version in ConsumerCoordinator
2016-01-04T00:03:30+00:00

Dana Powers
dana.powers@rd.io

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

5c45ec13f3e59d9c398f2d3035c762ca13589885

  - 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





  - 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

Dana Powers
dana.powers@rd.io

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

cb1b52f7056591d3964c7e4ba12c8fb21085b135