delta/python-packages/kafka-python.git/test/test_consumer_integration.py, branch initial_metadata_snapshot github.com: mumrah/kafka-python.git Fix typo 2017-07-01T09:37:52+00:00 Jeff Widman jeff@jeffwidman.com 2017-07-01T09:37:52+00:00 71ce772484cb43509742702c3f09ec7fde2923f7 






Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return more data than 0.10
2017-06-19T05:43:21+00:00

Dana Powers
dana.powers@gmail.com

2017-06-17T15:47:44+00:00

26a810220acbca57200a805132c5f32108a7fc9c












Increase max_buffer_size for test_large_messages
2017-06-19T05:43:21+00:00

Dana Powers
dana.powers@gmail.com

2017-06-17T15:46:54+00:00

c5f1c6901f0ff1b7867c80691134d535ac645559












Fix fetch_max_bytes=1 consumer integration test
2017-06-19T05:43:21+00:00

Dana Powers
dana.powers@gmail.com

2017-06-17T14:18:54+00:00

b4f71229d000b01c5d7b8054ce5eca5b69177bb1












Fix integration test that requires consumer group
2017-03-08T00:27:06+00:00

Dana Powers
dana.powers@gmail.com

2017-03-08T00:27:06+00:00

1813d7d21ed1d9e76d9078a2c70a7657e8c18d07












Added `max_bytes` option and FetchRequest_v3 usage. (#962)
2017-03-06T22:59:26+00:00

Taras Voinarovskyi
voyn1991@gmail.com

2017-03-06T22:59:26+00:00

9c19ea7cbe163b0c434ce9dd9c8c42471027cce5

* Added `max_bytes` option and FetchRequest_v3 usage.
* Add checks for versions above 0.10 based on ApiVersionResponse




* Added `max_bytes` option and FetchRequest_v3 usage.
* Add checks for versions above 0.10 based on ApiVersionResponse






KAFKA-3007: KafkaConsumer max_poll_records (#831)
2016-09-28T19:39:34+00:00

Dana Powers
dana.powers@gmail.com

2016-09-28T19:39:34+00:00

9ee77dfdbc4aeb5723ce7ebdae76f8b7141962af












* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages
2016-05-10T15:34:06+00:00

Paul Cavallaro
paulcavallaro@users.noreply.github.com

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

2c9930dea4a4537cf237ac7cc9db1f3970419b59

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages




* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages






Update imports from kafka.common -> kafka.errors / kafka.structs
2016-04-05T16:35:45+00:00

Dana Powers
dana.powers@gmail.com

2016-04-05T16:34:48+00:00

5a14bd8c947251d1a8f848175cc3cf2b07af3411












Support setting kafka instance port explicitly in fixture
2016-02-16T05:56:10+00:00

Dana Powers
dana.powers@gmail.com

2016-02-16T04:20:56+00:00

0d1ccc7485acf09b282d8cc7a06cfd94e690eddb