summaryrefslogtreecommitdiff
path: root/test/test_consumer_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-181-1/+23
|
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-221-0/+3
|
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-081-0/+7
|
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-211-21/+24
| | | | | | | This commits adds new pytest fixtures in prepation for the migration of unittest.TestCases to pytest test cases. The handling of temporary dir creation was also changed so that we can use the pytest tmpdir fixture after the migration.
* Increase some integration test timeouts (#1374)Dana Powers2018-02-081-4/+6
|
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-1/+2
|
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-111-2/+4
| | | | message format
* 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
|
View Lorry Controller Status