delta/python-packages/kafka-python.git/kafka, branch coordinator_tests

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

Add error checking to mark_for_reassignment

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

Move ConsumerProtocol definition to kafka.coordinator.protocol

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

Merge branch '0.9'

2016-01-08T02:51:14+00:00

Conflicts:
	kafka/codec.py
	kafka/version.py
	test/test_producer.py
	test/test_producer_integration.py

Fix KafkaClient->SimpleClient references

2016-01-08T01:57:24+00:00

Add metadata_max_age_ms and retry_backoff_ms options to async client

2016-01-08T01:08:32+00:00

Docstring updates

2016-01-08T01:03:08+00:00

Reorg kafka imports

2016-01-08T00:59:18+00:00

  - kafka.KafkaClient is new async client
  - kafka.SimpleClient is old sync client
  - update copyright / author info
  - add BrokerConnection; drop KafkaConnection

Fix future redefine bug in client.poll

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

Call errbacks with future.exception

2016-01-04T07:31:09+00:00