summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* | | | | Use 500ms zookeeper session timeout for integration tests - no network here, ↵Dana Powers2015-06-104-0/+12
| | | | | | | | | | | | | | | | | | | | and our restarts are fast
* | | | | 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
|/ /
* | Merge pull request #403 from dpkp/client_request_response_orderingDana Powers2015-06-102-11/+51
|\ \ | | | | | | Client request response ordering
| * | Fix KafkaClient request / response orderingDana Powers2015-06-101-10/+20
| | |
| * | Add KafkaClient test to show that request / response ordering is brokenDana Powers2015-06-101-1/+31
|/ /
* | Reduce replica timeouts to 1sec for failover integration testingDana Powers2015-06-104-0/+16
| |
* | Test failover integration with 3-brokers / replicas / partitionsDana Powers2015-06-091-3/+3
|/
* Add send/receive debug logging to async producerDana Powers2015-06-091-8/+11
|
* KafkaClient log new broker and topic metadata received as INFODana Powers2015-06-091-2/+2
|
* KafkaClient: log responses by requestId for debuggingDana Powers2015-06-091-1/+4
|
* KafkaClient: log requestId on ConnectionError instead of hexdump of request ↵Dana Powers2015-06-091-6/+5
| | | | contents
* Add thread id to logging format to assist with debugging test failuresDana Powers2015-06-091-0/+1
|
* Reset kafka.conn logger level in tearDownDana Powers2015-06-091-0/+13
|
* Merge pull request #398 from dpkp/kafka_consumer_failed_payloadsDana Powers2015-06-091-37/+61
|\ | | | | Kafka consumer failed payloads
| * KafkaConsumer style nitsDana Powers2015-06-081-26/+48
| |
| * Update KafkaConsumer to handle request-specific FailedPayloadsErrorsDana Powers2015-06-081-11/+13
| |
* | Merge pull request #396 from dpkp/sync_producer_fail_on_error_kwargDana Powers2015-06-092-4/+30
|\ \ | | | | | | Sync producer fail on error kwarg
| * | Support sync_fail_on_error kwarg in ProducerDana Powers2015-06-092-4/+30
|/ /
* | 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-096-17/+36
|\ \ | | | | | | 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
| | |
| * | Fail fast in nosetestsDana Powers2015-06-081-1/+1
| |/
* | Merge pull request #401 from dpkp/async_producer_responsesDana Powers2015-06-092-12/+60
|\ \ | |/ |/| Async producer responses
| * Use a list, not request_tries.keys(), to track requests / responses in async ↵Dana Powers2015-06-091-2/+4
| | | | | | | | producer
| * Add Unit test for async producer leader change; return ProduceResponse on ↵Dana Powers2015-06-091-10/+56
|/ | | | success
* Merge pull request #394 from dpkp/cleanupsDana Powers2015-06-088-152/+88
|\ | | | | Cleanups
| * Fixup for loop vars in kafka/protocol.pyDana Powers2015-06-081-14/+14
| |
| * Improve kafka client debug request/response loggingDana Powers2015-06-081-5/+5
| |
| * Prefer single quotes for stringsDana Powers2015-06-081-14/+12
| |
| * Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-083-5/+12
| |
| * Dont maintain all producer args / kwargs in subclass __init__ and docstrings ↵Dana Powers2015-06-082-91/+24
| | | | | | | | -- just refer to super class (Producer)
| * Cleanup imports in kafka/client and kafka/consumerDana Powers2015-06-083-23/+21
| |
* | 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
* Merge pull request #389 from dpkp/task_done_key_errorDana Powers2015-06-081-2/+10
|\ | | | | KafkaConsumer.task_done: warn and skip unrecognized topic-partitions
| * KafkaConsumer.task_done - warn and skip messages from unrecognized ↵Dana Powers2015-06-061-2/+10
| | | | | | | | topic-partitions
* | Merge pull request #393 from dpkp/simple_consumer_leader_changeDana Powers2015-06-082-2/+78
|\ \ | | | | | | Simple consumer leader change
| * | SimpleConsumer should refresh metadata and retry on leadership changes; only ↵Dana Powers2015-06-081-1/+4
| | | | | | | | | | | | raise on UnknownTopicOrPartition
| * | Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
|/ /
* | Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-082-5/+18
|\ \ | | | | | | Support optional partitions kwarg in MultiProcessConsumer
| * | Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-172-5/+18
| | |
* | | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-083-17/+18
|\ \ \ | | | | | | | | Deprecate KeyedProducer.send in favor of send_messages
| * | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-173-17/+18
| | | | | | | | | | | | | | | | consistent
View Lorry Controller Status