summaryrefslogtreecommitdiff
path: root/test/test_consumer_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* remove beginning/end offsets request version limitLiao Jiayi2017-09-041-6/+0
|
* Added unit tests for fetcher's `_reset_offset` and related functions.Taras Voinarovskiy2017-08-071-1/+1
|
* Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵Taras Voinarovskiy2017-08-071-1/+46
| | | | review issues
* Changed retrieve_offsets to allow fetching multiple offsets at onceTaras Voinarovskiy2017-08-071-4/+41
|
* Fix test for older brokersTaras Voinarovskiy2017-08-071-2/+4
|
* Added basic support for offsets_for_times API. Still needs to group by nodes ↵Taras Voinarovskiy2017-08-071-1/+45
| | | | and send in parallel.
* Fix typoJeff Widman2017-07-011-1/+1
|
* Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ↵Dana Powers2017-06-181-3/+0
| | | | more data than 0.10
* Increase max_buffer_size for test_large_messagesDana Powers2017-06-181-2/+8
|
* Fix fetch_max_bytes=1 consumer integration testDana Powers2017-06-181-10/+10
|
* Fix integration test that requires consumer groupDana Powers2017-03-071-1/+4
|
* Added `max_bytes` option and FetchRequest_v3 usage. (#962)Taras Voinarovskyi2017-03-061-0/+46
| | | | * 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)Dana Powers2016-09-281-0/+1
|
* * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ↵Paul Cavallaro2016-05-101-1/+18
| | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-4/+2
|
* Support setting kafka instance port explicitly in fixtureDana Powers2016-02-151-2/+4
|
* Fix missing importDana Powers2016-01-301-0/+1
|
* Skip MultiProcessConsumer integration testsDana Powers2016-01-301-0/+5
|
* Merge branch '0.9'Dana Powers2016-01-071-45/+57
|\ | | | | | | | | | | | | | | 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 testDana Powers2016-01-041-2/+1
| |
| * Dont use consumer_timeout_ms in kafka blocking testDana Powers2016-01-031-7/+4
| |
| * Update consumer integration tests to use new (group) KafkaConsumerDana Powers2016-01-031-29/+31
| | | | | | | | | | | | | | | | | | | | - 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 testDana Powers2015-12-101-1/+1
| |
| * Fix consumer integration test that assumed a single brokerDana Powers2015-12-101-4/+6
| |
| * Fix zk_chroot in consumer integration kafka fixturesDana Powers2015-12-101-2/+3
| |
| * Drop kafka_bytestringDana Powers2015-12-101-1/+1
| |
| * Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
| |
| * Default consumer integration tests should not use offset commitsDana Powers2015-12-091-2/+3
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-2/+2
| |
* | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-101-20/+5
|/
* Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-181-0/+18
| | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time.
* fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-201-0/+14
|
* Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-101-5/+5
|
* Reduce blocking times in consumer integration testsDana Powers2015-06-081-14/+14
|
* Import style nits in integration testsDana Powers2015-06-081-2/+6
|
* random_string helper should return str not bytesDana Powers2015-06-061-1/+1
|
* Make external API consistently support python3 strings for topic.Space2015-04-031-1/+1
|
* Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-301-1/+4
| | | | | | | | a group is configured (but document that group must be None for old servers). This fixes multiprocessor consumer issue that prevented access to commit offsets if auto_commit is disabled. Also refactor fetch_last_known_offsets based on KafkaConsumer While still setting unknown offsets to 0
* Skip these tests: no OffsetCommitRequest for 0.8.0Viktor Shlapakov2015-03-301-2/+2
|
* Added basic tests for load_initial_offsets optionViktor Shlapakov2015-03-301-0/+35
|
* Add test case for MP Consumer auto commitAli-Akber Saifee2015-03-301-0/+35
| | | | Tweak MP Consumer test to use iterator
* Use bootstrap_servers interface in testsDana Powers2015-03-291-1/+1
|
* Moving to **kwargs for MPConsumer optionsViktor Shlapakov2015-03-241-5/+3
|
* Using iter_timeout=0 for MP inner consumer in testsViktor Shlapakov2015-03-131-1/+4
|
* Retry failed partitions and add integration testsEnrico Canzonieri2015-01-261-1/+43
|
* Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-141-2/+2
|
* Make TIMEOUT_MS configurable in test_kafka_consumer__blockingDana Powers2014-12-151-4/+5
|
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-151-13/+15
|
* Fix task_done checks when no previous commit exists; add testDana Powers2014-12-151-0/+43
|
* Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵Dana Powers2014-12-151-2/+1
| | | | from kafka at top-level
View Lorry Controller Status