delta/python-packages/kafka-python.git/test/test_client.py, branch 1.0.2

Fix KafkaClient->SimpleClient references

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

Rename TopicAndPartition -> TopicPartition

2015-12-28T21:44:29+00:00

Switch BrokerConnection to (mostly) non-blocking IO.

2015-12-18T07:22:35+00:00

 - return kafka.Future on send()
 - recv is now non-blocking call that completes futures when possible
 - update KafkaClient to block on future completion

Drop kafka_bytestring

2015-12-11T02:37:03+00:00

Update client tests for new protocol usage

2015-12-09T23:46:36+00:00

Make external API consistently support python3 strings for topic.

2015-04-03T17:23:39+00:00

Add test for correlation_id rollover

2015-03-30T01:52:12+00:00

Use reflection to avoid multiple errno definitions

2015-01-11T02:57:36+00:00

Merge pull request #223 from dpkp/metadata_refactor

2014-09-08T20:17:43+00:00

Metadata Refactor

* add MetadataRequest and MetadataResponse namedtuples
* add TopicMetadata namedtuple
* add error codes to Topic and Partition Metadata
* add KafkaClient.send_metadata_request() method
* KafkaProtocol.decode_metadata_response changed to return a
  MetadataResponse object so that it is consistent with server api:
  [broker_list, topic_list]
* raise server exceptions in load_metadata_for_topics(*topics)
  unless topics is null (full refresh)
* Replace non-standard exceptions (LeaderUnavailable,
  PartitionUnavailable) with server standard exceptions
  (LeaderNotAvailableError, UnknownTopicOrPartitionError)

Conflicts:
	kafka/client.py
	test/test_client.py
	test/test_producer_integration.py
	test/test_protocol.py

Merge pull request #227 from wizzat-feature/py3

2014-09-08T02:09:32+00:00

Python 3 Support

Conflicts:
	kafka/producer.py
	test/test_client.py
	test/test_client_integration.py
	test/test_codec.py
	test/test_consumer.py
	test/test_consumer_integration.py
	test/test_failover_integration.py
	test/test_producer.py
	test/test_producer_integration.py
	test/test_protocol.py
	test/test_util.py