delta/python-packages/kafka-python.git/kafka/consumer, branch fetchgithub.com: mumrah/kafka-python.git
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
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
Drop now-redundant ready() check in Fetcher._handle_offset_response2016-04-04T21:42:49+00:00Dana Powersdana.powers@gmail.com2016-03-14T07:10:50+00:00ee7114cebbd926004bfce2d8fe0552cfeeb4a528
Merge pull request #602 from zackdever/KAFKA-26982016-03-17T18:22:36+00:00Dana Powersdana.powers@gmail.com2016-03-17T18:22:36+00:00ab03296b65b2031930a0f04d06502b156dd01657
KAFKA-2698: add paused API
KAFKA-2698: add paused API
Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS2016-03-17T18:21:48+00:00Dana Powersdana.powers@gmail.com2016-03-17T18:21:48+00:00f83e27168fe5f0d5c71b962b8788e05640ea8e2b