| Commit message (Expand) | Author | Age | Files | Lines |
|---|
| * | Split kafka.common into kafka.structs and kafka.errors | Dana Powers | 2016-04-05 | 1 | -488/+2 |
| * | Mark old kafka.common structs as Deprecated; remove unused TopicMetadata | Dana Powers | 2016-02-15 | 1 | -11/+10 |
| * | Small KafkaClient.check_version() improvements | Dana Powers | 2016-01-25 | 1 | -0/+4 |
| * | Use ConnectionError rather than new DisconnectError | Dana Powers | 2015-12-29 | 1 | -6/+2 |
| * | AbstractCoordinator (modelled after upstream Java class) | Dana Powers | 2015-12-28 | 1 | -0/+5 |
| * | Add OffsetAndMetadata namedtuple | Dana Powers | 2015-12-28 | 1 | -0/+3 |
| * | Use attributes on exception classes to signal retriable and invalid metadata ... | Dana Powers | 2015-12-28 | 1 | -11/+28 |
| * | Rename TopicAndPartition -> TopicPartition | Dana Powers | 2015-12-28 | 1 | -1/+1 |
| * | New async KafkaClient, based on java NetworkClient and ConsumerClient | Dana Powers | 2015-12-28 | 1 | -0/+8 |
| * | Update BrokerConnection for use with async client | Dana Powers | 2015-12-28 | 1 | -0/+4 |
| * | Rename Cluster -> ClusterMetadata; align with upstream Metadata class | Dana Powers | 2015-12-28 | 1 | -0/+4 |
| * | Switch BrokerConnection to (mostly) non-blocking IO. | Dana Powers | 2015-12-17 | 1 | -0/+16 |
| * | new 0.9 error codes plus descriptions. | Zack Dever | 2015-12-15 | 1 | -8/+170 |
| * | Convert OffsetCommit and OffsetFetch protocol encode/decode | Dana Powers | 2015-12-10 | 1 | -8/+8 |
| * | Change KafkaProtocol to encode/decode Structs, not bytes | Dana Powers | 2015-12-09 | 1 | -6/+6 |
| * | Support consumer metadata requests | tpalino | 2015-07-01 | 1 | -0/+22 |
| * | try to fix uncaught FailedPayloadsError | reAsOn2010 | 2015-06-09 | 1 | -0/+2 |
| * | FailedPayloadsError now only has a single payload; use .payload attribute | Dana Powers | 2015-06-06 | 1 | -2/+2 |
| * | Improve async producer code: logic and style fixes | Viktor Shlapakov | 2015-06-03 | 1 | -11/+6 |
| * | Fix names for async retries opts, add timeout for put | Viktor Shlapakov | 2015-06-03 | 1 | -2/+2 |
| * | Simplification of retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -1/+1 |
| * | Fix small issues with names/tests | Viktor Shlapakov | 2015-06-03 | 1 | -0/+4 |
| * | Clean and simplify retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -0/+17 |
| * | Improved retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -0/+3 |
| * | Fixed tests and other issues after rebase | Viktor Shlapakov | 2015-06-03 | 1 | -1/+0 |
| * | Retries for async batching | Viktor Shlapakov | 2015-06-03 | 1 | -2/+10 |
| * | Fixup indentation in kafka/common.py; add links to protocol definitions | Dana Powers | 2015-03-08 | 1 | -23/+26 |
| * | Add failed_payloads attribute to FailedPayloadsError | Job Evers | 2015-03-08 | 1 | -1/+3 |
| * | 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 |
| * | Use standard exceptions in client._get_leader_for_partition() | Dana Powers | 2014-09-01 | 1 | -4/+0 |
| * | 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 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 |
| * | Attempt to fix travis build. Decrease complexity of service.py in favor of in... | Mark Roberts | 2014-05-06 | 1 | -2/+8 |
| * | 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 wor... | Mark Roberts | 2014-04-08 | 1 | -0/+4 |
| * | Merge pull request #134 from wizzat/conn_refactorv0.9.0 | Dana Powers | 2014-03-21 | 1 | -15/+21 |
| |\ |
|
| | * | 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 |
| * | | 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, failed... | Jim Lim | 2013-10-04 | 1 | -0/+5 |
| * | 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 |
