| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix KafkaClient->SimpleClient references0.9 | Dana Powers | 2016-01-07 | 1 | -32/+32 |
| | | |||||
| * | Rename TopicAndPartition -> TopicPartition | Dana Powers | 2015-12-28 | 1 | -10/+10 |
| | | |||||
| * | Switch BrokerConnection to (mostly) non-blocking IO. | Dana Powers | 2015-12-17 | 1 | -35/+47 |
| | | | | | | | - 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 | Dana Powers | 2015-12-10 | 1 | -9/+8 |
| | | |||||
| * | Update client tests for new protocol usage | Dana Powers | 2015-12-09 | 1 | -74/+61 |
| | | |||||
| * | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 1 | -34/+36 |
| | | |||||
| * | Add test for correlation_id rollover | Dana Powers | 2015-03-29 | 1 | -0/+8 |
| | | |||||
| * | Use reflection to avoid multiple errno definitions | Alex Couture-Beil | 2015-01-10 | 1 | -3/+2 |
| | | |||||
| * | Merge pull request #223 from dpkp/metadata_refactor | Dana Powers | 2014-09-08 | 1 | -79/+218 |
| |\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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 | ||||
| | * | Add client unit tests for has_metadata_for_topic and ensure_topic_exists | Dana Powers | 2014-09-01 | 1 | -1/+63 |
| | | | |||||
| | * | Add test for sending produce request to unknown topic w/o auto-creation | Dana Powers | 2014-09-01 | 1 | -0/+25 |
| | | | |||||
| | * | Use standard exceptions in client._get_leader_for_partition() | Dana Powers | 2014-09-01 | 1 | -8/+18 |
| | | | | | | | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises | ||||
| | * | load_metadata_for_topics should raise exceptions on explicit topic args | Dana Powers | 2014-09-01 | 1 | -25/+46 |
| | | | |||||
| | * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableError | Dana Powers | 2014-09-01 | 1 | -2/+2 |
| | | | |||||
| | * | Improve metadata protocol handling | Dana Powers | 2014-09-01 | 1 | -68/+90 |
| | | | | | | | | | | | | | | | | | | | | | - 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] | ||||
| * | | Merge pull request #227 from wizzat-feature/py3 | Dana Powers | 2014-09-07 | 1 | -16/+19 |
| |\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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 | ||||
| | * | | Fix test errors related to mocks | Mark Roberts | 2014-09-03 | 1 | -3/+6 |
| | | | | |||||
| | * | | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -10/+11 |
| | | | | |||||
| | * | | Use base unittest or unittest2 depending on python version | Bruno Renié | 2014-09-03 | 1 | -2/+2 |
| | |/ | |||||
| * | | Fix socket timeout test -- mock the side_effect | Dana Powers | 2014-09-01 | 1 | -1/+19 |
| |/ | |||||
| * | Add pylint to tox.ini; test both kafka and test; default to error-checking ↵ | Dana Powers | 2014-08-25 | 1 | -6/+1 |
| | | | | | only; fixup errors; skip kafka/queue.py | ||||
| * | Fix Python 2.6 support | Mark Roberts | 2014-04-23 | 1 | -2/+2 |
| | | |||||
| * | Refactor away _get_conn_for_broker. Fix bug in _get_conn | Mark Roberts | 2014-04-09 | 1 | -1/+1 |
| | | |||||
| * | Split test files, modify test_protocol | Mark Roberts | 2014-04-08 | 1 | -15/+237 |
| | | |||||
| * | Remove test support for py26 since it's broken | Mark Roberts | 2014-04-07 | 1 | -0/+27 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |