delta/python-packages/kafka-python.git/kafka/consumer, branch task_poll_timeout github.com: mumrah/kafka-python.git Improve KafkaConsumer iterator loop timeouts 2016-01-10T23:47:35+00:00 Dana Powers dana.powers@rd.io 2016-01-10T23:47:33+00:00 98e4ab3cb931ee110faa22f6afa6c72523e24db9 - Consider all delayed tasks, not just heartbeat - Include metadata update timeout - Fix second / millisecond bug calling client.poll() 
  - Consider all delayed tasks, not just heartbeat
  - Include metadata update timeout
  - Fix second / millisecond bug calling client.poll()
Remove old kafka.consumer.kafka module 2016-01-10T20:49:47+00:00 Dana Powers dana.powers@rd.io 2016-01-10T20:49:47+00:00 7ee73df4c4bb3c69ac38accc30ff68bc6d64d594 






KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync
2016-01-10T20:06:04+00:00

Dana Powers
dana.powers@rd.io

2016-01-10T00:52:01+00:00

9837927c70abd3e032a9aefbd2990a7605276670












Add error checking to mark_for_reassignment
2016-01-10T16:57:52+00:00

Dana Powers
dana.powers@rd.io

2016-01-10T08:34:23+00:00

35ed2e75dab2ba44b57f4e7183ebc020f3121124












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












Docstring updates
2016-01-08T01:03:08+00:00

Dana Powers
dana.powers@rd.io

2016-01-08T01:03:08+00:00

e080c6b0cdb54563e3c5ad595d582de26561d9f0












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












Switch to new KafkaConsumer in module imports
2016-01-04T00:14:37+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T00:14:37+00:00

0334fee5509b8cb3fd6ca3c1a6025804be978107












Add deprecated methods to KafkaConsumer w/ notes on alternatives
2016-01-04T00:12:22+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T00:12:22+00:00

df75751238f2ccc731d9881c92dfcc524c57aeaf












Disable pylint error on __iter__ (next is provided via six.Iterator)
2016-01-04T00:09:52+00:00

Dana Powers
dana.powers@rd.io

2016-01-04T00:09:52+00:00

71af307f4e350a0e3ef21a6c986ebebb6717dc15