delta/python-packages/kafka-python.git/kafka/consumer, branch conn_state_callbackgithub.com: mumrah/kafka-python.git
Default sleep=True in client.poll2016-04-08T16:23:57+00:00Dana Powersdana.powers@gmail.com2016-04-07T23:13:50+00:006662d1e6247f809b04a8fc7cb539a5dd02ed9b65
KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)2016-04-06T21:48:13+00:00Dana Powersdana.powers@gmail.com2016-04-05T20:04:24+00:003d16f2ff5f75380c8a9fce846f35e92bb5bfb935
Merge pull request #634 from dpkp/fetch2016-04-06T21:00:28+00:00Dana Powersdana.powers@gmail.com2016-04-06T21:00:28+00:00331442ee0fcc0d888c2b2d2ed4f2a339d167b4a2
Small improvements to fetching logic
Small improvements to fetching logic
Dont send FetchRequest for (obviously) pending data2016-04-06T18:47:41+00:00Dana Powersdana.powers@gmail.com2016-04-06T18:47:41+00:0078ad43600c469c05a5b0e32c6be27048749cd58e
Increase coverage of StopIteration check in _unpack_message_set2016-04-06T18:47:07+00:00Dana Powersdana.powers@gmail.com2016-04-06T18:47:07+00:003ef15f9d60af01ce397737b4d356618385b8884f
Log debug messages when skipping fetched messages due to offset checks2016-04-06T18:46:20+00:00Dana Powersdana.powers@gmail.com2016-04-06T18:46:20+00:00358b4820744c42d47171f17a5b373a1c89f520bb
Use version-indexed lists for request/response protocol structs2016-04-06T05:54:28+00:00Dana Powersdana.powers@gmail.com2016-04-06T05:54:28+00:0090c729438a2e3f1b194e58231e41bd16bd7b7172
KAFKA-3318: clean up consumer logging and error messages2016-04-05T17:22:54+00:00Dana Powersdana.powers@gmail.com2016-04-05T07:07:15+00:00145ac227cb7f471467de52c5016ed3727e417911
Update imports from kafka.common -> kafka.errors / kafka.structs2016-04-05T16:35:45+00:00Dana Powersdana.powers@gmail.com2016-04-05T16:34:48+00:005a14bd8c947251d1a8f848175cc3cf2b07af3411