delta/python-packages/kafka-python.git/kafka/consumer, branch lz4

Disable offset commits and auto-partition-assignment when group_id is None

2016-01-25T02:38:26+00:00

Merge pull request #507 from dpkp/deprecation_warnings

2016-01-13T06:57:24+00:00

Add DeprecationWarnings to legacy classes

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

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

Sleep in KafkaConsumer iterator if no partition assignment; dont block in poll if no in-flight fetches

2016-01-12T23:39:48+00:00

Move consumer_timeout handling to private method

2016-01-12T22:42:17+00:00

Attempt to pipeline fetchrequests in iterator

2016-01-12T22:41:22+00:00

Use private deque to track in-flight fetchrequests

2016-01-12T22:38:16+00:00

Update docstring and comments in _create_fetch_requests re KAFKA-2978

2016-01-11T07:00:10+00:00

Reorganize init_fetches calls during iteration

2016-01-11T07:00:10+00:00

  Generally should not init_fetches while the generator has pending
  messages; this revision adds an explicit check / noop to the
  public interface, and uses a private method internally to
  attempt to pipeline fetch requests.

Check for assignment changes before yielding new record

2016-01-11T07:00:09+00:00