summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
* Convert codec tests to pytest; add simple lz4 testDana Powers2016-01-251-62/+75
|
* Disable auto-commit / group assignment in producer testgroup_id_noneDana Powers2016-01-241-0/+1
|
* Add simple KafkaProducer -> KafkaConsumer integration testDana Powers2016-01-241-0/+34
|
* add DefaultPartitioner testDana Powers2016-01-241-22/+42
|
* Move pytest broker/zk fixtures to test.conftestDana Powers2016-01-243-30/+36
|
* Rename legacy producer testsDana Powers2016-01-241-0/+0
|
* Fix client poll tests (called with sleep=False)Dana Powers2016-01-231-4/+5
|
* Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warningsDana Powers2016-01-121-8/+7
| | | | and KafkaConnection
* Add mocking to test_coordinator::test_close to fix random test failure (via ↵Dana Powers2016-01-111-0/+1
| | | | travis logs)
* Fix delayed_task timeout commit 45d26b6Dana Powers2016-01-101-3/+3
|
* Merge pull request #502 from dpkp/task_poll_timeoutDana Powers2016-01-101-2/+28
|\ | | | | Add delayed task timeouts to _poll calls
| * Check delayed task timeout in client.poll()Dana Powers2016-01-101-2/+28
| |
* | Log generation and member_id in threaded consumer group testDana Powers2016-01-101-1/+4
|/
* Merge pull request #501 from dpkp/coordinator_testsDana Powers2016-01-101-0/+568
|\ | | | | ConsumerCoordinator cleanups and test coverage
| * Add ConsumerCoordinator unit testsDana Powers2016-01-101-0/+568
| |
* | Fill out more async client unit testsDana Powers2016-01-091-18/+165
|/
* Remove errant kafka_versions('all') from 0.9 mergeDana Powers2016-01-071-1/+0
|
* Merge branch '0.9'Dana Powers2016-01-0715-297/+596
|\ | | | | | | | | | | | | | | Conflicts: kafka/codec.py kafka/version.py test/test_producer.py test/test_producer_integration.py
| * Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-075-44/+44
| |
| * Drop request_timeout_ms override in consumer group testDana Powers2016-01-041-2/+1
| |
| * 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
| |
| * Fast heartbeats during consumer group testsDana Powers2016-01-031-0/+1
| |
| * Import queue from six.movesDana Powers2016-01-031-10/+3
| |
| * Add pytests for KafkaConsumer group assignmentsDana Powers2016-01-031-0/+170
| |
| * Use parameterized pytests in test_client_async; add pytest-mocker pluginDana Powers2016-01-031-70/+94
| |
| * Use 2-second KafkaClient timeout in failover testsDana Powers2016-01-031-1/+1
| |
| * 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
| * bootstrap_servers no longer required in KafkaConsumer (localhost default)Dana Powers2016-01-031-4/+0
| |
| * Disable pylint errors for py2/py3 compatibility workaroundsDana Powers2016-01-011-1/+1
| |
| * Skeleton tests for async kafka clientDana Powers2016-01-011-0/+103
| |
| * Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)Dana Powers2015-12-301-0/+2
| |
| * Catch and retry on RequestTimedOutError in producer failover testDana Powers2015-12-291-2/+4
| |
| * Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-285-19/+19
| |
| * Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-35/+47
| | | | | | | | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
| * Drop bytes encoding of consumer group in consumer integration testDana Powers2015-12-101-1/+1
| |
| * Remove bytes encoding for topic name in producer integration testDana Powers2015-12-101-1/+1
| |
| * Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-102-21/+0
| | | | | | | | and reenable kafka.conn debug logging in tests
| * pylint fixesDana Powers2015-12-102-1/+2
| | | | | | | | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
| * Remove KafkaProtocol._decode_messageDana Powers2015-12-101-0/+2
| |
| * 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-106-33/+28
| |
| * Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
| |
| * Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-103-7/+7
| |
| * Fix test_consumer generator/list mock, reenable testsDana Powers2015-12-101-5/+2
| |
| * Update kafka.common imports to Payloads namedtuples in test_protocolDana Powers2015-12-091-22/+24
| |
| * Default consumer integration tests should not use offset commitsDana Powers2015-12-091-2/+3
| |
| * Skip protocol tests for now -- need updatingDana Powers2015-12-091-0/+20
| |
| * Update to Payload namedtuples in consumer testsDana Powers2015-12-091-4/+4
| |
View Lorry Controller Status