Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | |||||
* | Simplify RecordMetadata; short circuit callbacks (#768) | Dana Powers | 2016-07-17 | 1 | -1/+2 |
| | | | | Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks | ||||
* | Cleanup error logging (#760 / #759) | Dana Powers | 2016-07-15 | 1 | -1/+1 |
| | | | | | | - add error type to all KafkaErrors - add args to BrokerResponseError - drop description from BrokerResponseError - fix bug logging errbacks as callbacks | ||||
* | use the same logic for callbacks regardless of is_done status | Zack Dever | 2016-04-25 | 1 | -12/+15 |
| | |||||
* | Remove unused importskafka-3318 | Dana Powers | 2016-04-05 | 1 | -2/+0 |
| | |||||
* | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -1/+1 |
| | |||||
* | Coerce exceptions to bool in Future.succeeded() and Future.failed() | Dana Powers | 2016-04-05 | 1 | -2/+2 |
| | |||||
* | Call errbacks with future.exception | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | |||||
* | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -8/+4 |
| | |||||
* | Improvements to kafka.future.Future | Dana Powers | 2015-12-28 | 1 | -8/+37 |
| | | | | | | | | - log exceptions in callbacks/errors - dont raise - guarantee future.exception is an instance, not a class/type - *args, **kwargs in add_callback / errback (functools.partial) - add_both(f, *args, **kwargs) to add same f as callback and errback - chain(new_future) to trigger new_future on success / failure of this | ||||
* | Use attributes on exception classes to signal retriable and invalid metadata ↵ | Dana Powers | 2015-12-28 | 1 | -2/+5 |
| | | | | errors | ||||
* | Switch BrokerConnection to (mostly) non-blocking IO. | Dana Powers | 2015-12-17 | 1 | -0/+51 |
- return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion |