summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
* | Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-021-0/+14
|\ \ | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
| | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-022-2/+44
|\ \ \ | |_|/ |/| | Allow null payload for deletion feature
| * | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1
| | |
| * | Add KeyedProducer test with null payloadsViktor Shlapakov2015-06-171-0/+22
| | |
| * | Add basic keyed producer testsViktor Shlapakov2015-06-171-2/+22
| | |
* | | fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-201-0/+14
| |/ |/|
* | Increase timeout and backoff when retrying spawn of test fixturesDana Powers2015-06-111-2/+16
| |
* | Merge pull request #402 from dpkp/kafka_0_8_2_1Dana Powers2015-06-102-6/+6
|\ \ | | | | | | Use kafka 0.8.2.1 in integration tests
| * | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-102-6/+6
| | |
* | | Merge pull request #404 from dpkp/consumer_more_exception_handlingDana Powers2015-06-101-2/+42
|\ \ \ | |/ / |/| | Consumer - handle exceptions in commit() and reset_partition_offset()
| * | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵Dana Powers2015-06-101-1/+16
| | | | | | | | | | | | failure
| * | (test) Consumer commit() should log errors and return True/False, not raise ↵Dana Powers2015-06-101-0/+24
| | | | | | | | | | | | exceptions
| * | Split consumer test class between Simple and MultiProcessDana Powers2015-06-101-1/+2
| | |
* | | Use at_least=True when counting messages in leader failover testsDana Powers2015-06-101-1/+4
|/ /
* | Retry failed messages in failover integration tests; use module loggerDana Powers2015-06-101-12/+17
| |
* | Remove 1 sec timeout on topic creation in client response ordering testDana Powers2015-06-101-2/+2
| |
* | Add KafkaClient test to show that request / response ordering is brokenDana Powers2015-06-101-1/+31
| |
* | Test failover integration with 3-brokers / replicas / partitionsDana Powers2015-06-091-3/+3
|/
* Reset kafka.conn logger level in tearDownDana Powers2015-06-091-0/+13
|
* Support sync_fail_on_error kwarg in ProducerDana Powers2015-06-091-2/+18
|
* Create a new child thread on each open fixture tryDana Powers2015-06-091-6/+7
|
* Merge pull request #397 from dpkp/test_loggingDana Powers2015-06-095-16/+35
|\ | | | | Test logging
| * Dont try to terminate a child that has already exited in test/service _despawnDana Powers2015-06-081-1/+2
| |
| * Produce messages to both partitions in async producer leader switch testDana Powers2015-06-081-1/+9
| |
| * Reduce blocking times in consumer integration testsDana Powers2015-06-081-14/+14
| |
| * Reduce log chatter in tests (only debug kafka.conn in test_conn)Dana Powers2015-06-082-0/+10
| |
* | Add Unit test for async producer leader change; return ProduceResponse on ↵Dana Powers2015-06-091-10/+56
|/ | | | success
* Import style nits in integration testsDana Powers2015-06-084-7/+10
|
* Add zk to KafkaIntegrationTestCase attributes to fix lint errorDana Powers2015-06-081-0/+1
|
* Dump fixture logs on OffsetResponse error during producer integrationDana Powers2015-06-081-3/+9
| | | | | tests. This is intended to help debug an intermittent failure that requires server logs.
* Retry with shorter 5sec timeout when trying to open() fixturesDana Powers2015-06-082-7/+14
| | | | | - this is intended to reduce flapping tests caused by intermittent - fixture startup issues on travis-ci
* Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
|
* Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-081-2/+11
|\ | | | | Support optional partitions kwarg in MultiProcessConsumer
| * Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-2/+11
| |
* | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-10/+10
|\ \ | | | | | | Deprecate KeyedProducer.send in favor of send_messages
| * | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-171-10/+10
| |/ | | | | | | consistent
* | try to fix uncaught FailedPayloadsErrorreAsOn20102015-06-091-0/+8
| |
* | Respawn crashed services in test/service.py, rather than raise RuntimeErrorDana Powers2015-06-071-12/+26
| |
* | Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-062-19/+2
| |
* | Encode random_message strings to bytes in test_failover_integrationDana Powers2015-06-061-1/+2
| |
* | Small hanging indent style nits in some producer integration testsDana Powers2015-06-061-4/+8
| |
* | Sleep for 500ms before retrying consumer pending call in testsDana Powers2015-06-061-0/+1
| |
* | test_batched_simple_producer__triggers_by_message should wait for producer ↵Dana Powers2015-06-061-0/+10
| | | | | | | | queue to drain before testing messages were sent
* | Include message number in sent message value in _send_random_messageDana Powers2015-06-061-1/+1
| |
* | add option to check for at-least-once message delivery in failover testsDana Powers2015-06-061-6/+12
| |
* | Reenable test_switch_leader_asyncDana Powers2015-06-061-7/+13
| |
* | FailedPayloadsError now only has a single payload; use .payload attributeDana Powers2015-06-061-2/+2
| | | | | | | | .failed_payloads attribute has been removed.
* | random_string helper should return str not bytesDana Powers2015-06-064-17/+16
| |
* | Raise an error if we attempt to group duplicate topic-partition payloadsDana Powers2015-06-061-1/+5
| | | | | | | | - previously this would simply drop one of the payloads
View Lorry Controller Status