| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Use reflection to avoid multiple errno definitions | Alex Couture-Beil | 2015-01-10 | 1 | -24/+12 |
| | | |||||
| * | Use configure() to check and set configuration keys | Dana Powers | 2014-12-15 | 1 | -0/+4 |
| | | |||||
| * | A simpler kafka consumer: | Dana Powers | 2014-12-15 | 1 | -0/+7 |
| | | | | | | | | | | | | | | | | | | | ``` kafka = KafkaConsumer('topic1') for m in kafka: print m kafka = KafkaConsumer('topic1', 'topic2', group_id='my_consumer_group', auto_commit_enable=True, auto_commit_interval_ms=30 * 1000, auto_offset_reset='smallest') for m in kafka: process_message(m) kafka.task_done(m) ``` | ||||
| * | Use standard exceptions in client._get_leader_for_partition() | Dana Powers | 2014-09-01 | 1 | -4/+0 |
| | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises | ||||
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableError | Dana Powers | 2014-09-01 | 1 | -4/+0 |
| | | |||||
| * | if error code is not recognized in check_error: raise UnknownError | Dana Powers | 2014-09-01 | 1 | -2/+6 |
| | | |||||
| * | Improve metadata protocol handling | Dana Powers | 2014-09-01 | 1 | -7/+23 |
| | | | | | | | | | | | - 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] | ||||
| * | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a test | Dana Powers | 2014-08-14 | 1 | -0/+4 |
| | | |||||
| * | Improve error handling and tests w.r.t. codecs | Patrick Lucas | 2014-05-07 | 1 | -0/+6 |
| | | | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function. | ||||
| * | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵ | Mark Roberts | 2014-05-06 | 1 | -2/+8 |
| | | | | | in memory logging. Address code review concerns | ||||
| * | Make BrokerRequestError a base class, make subclasses for each broker error | Mark Roberts | 2014-04-30 | 1 | -25/+89 |
| | | |||||
| * | Explicit testing of protocol errors. Make tests more explicit, and start ↵ | Mark Roberts | 2014-04-08 | 1 | -0/+4 |
| | | | | | working on intermittent failures in test_encode_fetch_request and test_encode_produc_request | ||||
| * | Merge pull request #134 from wizzat/conn_refactorv0.9.0 | Dana Powers | 2014-03-21 | 1 | -15/+21 |
| |\ | | | | | conn.py performance improvements, make examples work, add another example | ||||
| | * | Fix grammar in error string | Mark Roberts | 2014-02-25 | 1 | -1/+1 |
| | | | |||||
| | * | Minor refactor in conn.py, update version in __init__.py, add ErrorString | Mark Roberts | 2014-02-25 | 1 | -15/+21 |
| | | | |||||
| * | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ↵ | mrtheb | 2014-02-15 | 1 | -0/+4 |
| | | | | | | | | | clarity | ||||
| * | | Handle cases for partition with leader=-1 (not defined) | Marc Labbe | 2014-01-31 | 1 | -4/+0 |
| |/ | |||||
| * | Throw KafkaUnavailableError when no brokers available | Thomas Dimson | 2014-01-13 | 1 | -0/+4 |
| | | |||||
| * | Exception hierarchy, invalidate more md on errors | Thomas Dimson | 2014-01-13 | 1 | -6/+25 |
| | | |||||
| * | make changes to be more fault tolerant: clean up connections, brokers, ↵ | Jim Lim | 2013-10-04 | 1 | -0/+5 |
| | | | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception | ||||
| * | style: fix whitespaces | Vetoshkin Nikita | 2013-10-03 | 1 | -0/+4 |
| | | |||||
| * | Fix #44 Add missing exception classv0.8.0 | David Arthur | 2013-09-24 | 1 | -0/+16 |
| | | | | | Also move the exceptions to common instead of util | ||||
| * | PEP8-ify most of the files | Mahendra M | 2013-05-29 | 1 | -11/+34 |
| | | | | | consumer.py and conn.py will be done later after pending merges | ||||
| * | Big code re-org | David Arthur | 2013-04-02 | 1 | -0/+43 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |