delta/python-packages/kafka-python.git/test/test_consumer_integration.py, branch 1.3.0

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages

2016-05-10T15:34:06+00:00

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Support setting kafka instance port explicitly in fixture

2016-02-16T05:56:10+00:00

Fix missing import

2016-01-31T02:24:07+00:00

Skip MultiProcessConsumer integration tests

2016-01-30T22:07:39+00:00

Merge branch '0.9'

2016-01-08T02:51:14+00:00

Conflicts:
	kafka/codec.py
	kafka/version.py
	test/test_producer.py
	test/test_producer_integration.py

Dont use consumer_timeout_ms in simple kafka_consumer test

2016-01-04T08:19:38+00:00

Dont use consumer_timeout_ms in kafka blocking test

2016-01-04T06:46:18+00:00

Update consumer integration tests to use new (group) KafkaConsumer

2016-01-04T00:23:17+00:00

  - Remove debug call to deprecated .offsets() method
  - Manually assign TopicPartition to avoid group subscription overhead
  - Use next(consumer), not consumer.next()
  - consumer_timeout_ms now raises StopIteration, not ConsumerTimeout
  - auto_commit_enable is now enable_auto_commit
  - auto_offset_reset -> earliest, not smallest
  - new consumer does not support auto_commit_interval_messages

Drop bytes encoding of consumer group in consumer integration test

2015-12-11T02:52:44+00:00