delta/python-packages/kafka-python.git/kafka/consumer/multiprocess.py, branch cleanup-testing-doc github.com: mumrah/kafka-python.git Don't use `kafka.common` internally 2018-06-05T21:32:01+00:00 Jeff Widman jeff@jeffwidman.com 2018-05-28T22:58:26+00:00 bc4cc434cddf403a35d0393d68ecfdbfad17c8e5 This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. 
This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
use absolute imports everywhere (#1362) 2018-02-06T20:10:45+00:00 Kevin Tindall kevinkjt2000@users.noreply.github.com 2018-02-06T20:10:45+00:00 9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6 






Vendor six 1.10.0
2016-08-01T21:47:40+00:00

Dana Powers
dana.powers@gmail.com

2016-08-01T16:45:39+00:00

51b3d311f3930d9bb86877ca235156eb9d46763c












Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection
2016-01-13T00:52:30+00:00

Dana Powers
dana.powers@rd.io

2016-01-13T00:52:30+00:00

4079a582b07989e683bcb2d87f6d522ed61a4f66












Fix KafkaClient->SimpleClient references
2016-01-08T01:57:24+00:00

Dana Powers
dana.powers@rd.io

2016-01-08T01:57:24+00:00

9a8af1499ca425366d934487469d9977fae7fe5f












Import queue from six.moves
2016-01-04T06:10:25+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T03:50:21+00:00

03d37dff5c707599e2f268dccb4cccafbeadd5e3












Fix _mp_consume queue variable name conflict
2015-12-09T22:06:00+00:00

Dana Powers
dana.powers@rd.io

2015-12-09T21:56:49+00:00

58bdeb17d7e337c48ee2c14bf1f73b00eed0e727












Fix python3 / python2 comments re queue/Queue
2015-12-02T23:00:35+00:00

Dana Powers
dana.powers@rd.io

2015-12-02T23:00:35+00:00

ee6b9cb5b1310c48a3ed5b66be0dd0c4dd16dc43












Merge pull request #457 from saaros/block-for-number-of-messages
2015-12-02T21:50:22+00:00

Dana Powers
dana.powers@gmail.com

2015-12-02T21:50:22+00:00

2eca5538eef948ef3828be5c3cb5c78c1c958f6f

Consumers get_messages: allow blocking until some messages are received




Consumers get_messages: allow blocking until some messages are received






Merge pull request #456 from barricadeio/mp-retry
2015-12-02T21:45:54+00:00

Dana Powers
dana.powers@gmail.com

2015-12-02T21:45:54+00:00

da217442c18090a6e8b615a3af17f0bdd93c14c8

Support retry semantics in MultiProcessConsumer




Support retry semantics in MultiProcessConsumer