summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
| * | Add client unit tests for has_metadata_for_topic and ensure_topic_existsDana Powers2014-09-011-1/+63
| | |
| * | Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-012-2/+27
| | |
| * | Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-015-37/+48
| | | | | | | | | | | | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises
| * | Raise UnknownTopicOrPartitionError immediately in ensure_topic_exists -- ↵Dana Powers2014-09-011-0/+4
| | | | | | | | | | | | server is not auto-creating
| * | load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-012-37/+86
| | |
| * | Dont need to use callbacks for offset fetch requestsDana Powers2014-09-011-4/+3
| | |
| * | Refactor internal metadata dicts in KafkaClientDana Powers2014-09-014-33/+69
| | | | | | | | | | | | | | | | | | | | | | | | - use helper methods not direct access - add get_partition_ids_for_topic - check for topic and partition errors during load_metadata_for_topics - raise LeaderNotAvailableError when topic is being auto-created or UnknownTopicOrPartitionError if auto-creation off
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-014-11/+6
| | |
| * | if error code is not recognized in check_error: raise UnknownErrorDana Powers2014-09-011-2/+6
| | |
| * | Rearrange KafkaClient method order to group client metadata methods togetherDana Powers2014-09-011-18/+18
| | |
| * | Improve metadata protocol handlingDana Powers2014-09-015-145/+192
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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]
* | | Updating AUTHORS.md with latest top contributorsDavid Arthur2014-09-081-13/+5
| | | | | | | | | Narrowed it down to the top 10 contributors since the list was getting kind of long (a nice problem to have!)
* | | Add six to tox.ini testing depsDana Powers2014-09-071-0/+1
| | |
* | | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-0728-344/+444
|\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | | Update kafka.util.crc32 to unsigned everywhereMark Roberts2014-09-032-13/+4
| | | |
| * | | Fix the multiprocessing tests for python 3Mark Roberts2014-09-033-3/+3
| | | |
| * | | Fix test errors related to mocksMark Roberts2014-09-032-6/+10
| | | |
| * | | Merge branch 'feature/py3' of https://github.com/brutasse/kafka-python into ↵Mark Roberts2014-09-030-0/+0
| |\ \ \ | | | | | | | | | | | | | | | feature/py3
| | * | | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-08-298-23/+39
| | | | |
| | * | | Bytes in self.msg()Bruno Renié2014-08-292-2/+2
| | | | |
| | * | | Use built-in next()Bruno Renié2014-08-292-3/+3
| | | | |
| | * | | Cross-python iteritemsBruno Renié2014-08-291-1/+3
| | | | |
| | * | | More bytes topicsBruno Renié2014-08-292-2/+2
| | | | |
| | * | | Encode topic directlyBruno Renié2014-08-291-1/+2
| | | | |
| | * | | Fix bytes interpolationBruno Renié2014-08-291-1/+1
| | | | |
| | * | | Topic in bytesBruno Renié2014-08-281-1/+1
| | | | |
| | * | | client_id in bytesBruno Renié2014-08-281-1/+1
| | | | |
| | * | | Fix stderr captureBruno Renié2014-08-281-1/+1
| | | | |
| | * | | Fix log capture on py3Bruno Renié2014-08-281-1/+1
| | | | |
| | * | | Make all unit tests pass on py3.3/3.4Bruno Renié2014-08-2822-272/+350
| | | | |
| | * | | Use base unittest or unittest2 depending on python versionBruno Renié2014-08-2813-30/+43
| | | |/ | | |/|
| * | | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-038-23/+39
| | | |
| * | | Bytes in self.msg()Bruno Renié2014-09-032-2/+2
| | | |
| * | | Use built-in next()Bruno Renié2014-09-032-3/+3
| | | |
| * | | Cross-python iteritemsBruno Renié2014-09-031-1/+3
| | | |
| * | | More bytes topicsBruno Renié2014-09-032-2/+2
| | | |
| * | | Encode topic directlyBruno Renié2014-09-031-1/+2
| | | |
| * | | Fix bytes interpolationBruno Renié2014-09-031-1/+1
| | | |
| * | | Topic in bytesBruno Renié2014-09-031-1/+1
| | | |
| * | | client_id in bytesBruno Renié2014-09-031-1/+1
| | | |
| * | | Fix stderr captureBruno Renié2014-09-031-1/+1
| | | |
| * | | Fix log capture on py3Bruno Renié2014-09-031-1/+1
| | | |
| * | | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-0322-271/+349
| | | |
| * | | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-0313-30/+43
| | |/ | |/|
* | | Merge pull request #221 from dpkp/minor_cleanupsDana Powers2014-09-0715-113/+129
|\ \ \ | | | | | | | | Minor cleanups
| * | | Cleanup tests: no more import *; remove unusedDana Powers2014-09-049-54/+26
| | | |
| * | | Another attempt to fix failover test flappingDana Powers2014-09-041-16/+23
| | | |
| * | | Import cleanups in testsDana Powers2014-09-046-24/+38
| | | |
| * | | Add a little more detail to test instructions in READMEDana Powers2014-09-041-3/+16
| | | |
| * | | Add simple PyPI install instructions and link to releases in READMEDana Powers2014-09-041-0/+9
| | | |
View Lorry Controller Status