delta/python-packages/kafka-python.git/kafka/future.py, branch lz4 github.com: mumrah/kafka-python.git Call errbacks with future.exception 2016-01-04T07:31:09+00:00 Dana Powers dana.powers@rd.io 2016-01-04T07:31:09+00:00 bb433e27f020597f3807cb4058d1e45a671cea6e 






Prefer assert or more-specific error to IllegalState / IllegalArgument
2015-12-31T00:16:13+00:00

Dana Powers
dana.powers@rd.io

2015-12-31T00:16:13+00:00

422050f952344e4796725d88db55a983bae4e1ee












Improvements to kafka.future.Future
2015-12-28T22:57:54+00:00

Dana Powers
dana.powers@rd.io

2015-12-28T21:24:37+00:00

87257bddf23850774794d4dc070a15ddddbd7830

 - 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





 - 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 errors
2015-12-28T21:45:23+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T09:43:57+00:00

d2af5b37ce53fcde6e9f3ee1b587c1ee1de19d2c












Switch BrokerConnection to (mostly) non-blocking IO.
2015-12-18T07:22:35+00:00

Dana Powers
dana.powers@rd.io

2015-12-18T01:29:54+00:00

f1ad0247df5bf6e0315ffbb1633d5979da828de0

 - return kafka.Future on send()
 - recv is now non-blocking call that completes futures when possible
 - update KafkaClient to block on future completion





 - return kafka.Future on send()
 - recv is now non-blocking call that completes futures when possible
 - update KafkaClient to block on future completion