summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* | Increase timeout and backoff when retrying spawn of test fixturesDana Powers2015-06-111-2/+16
| |
* | Merge pull request #378 from dpkp/murmur2_hashed_partitionerDana Powers2015-06-102-3/+98
|\ \ | | | | | | Use MurmurHash2 for key partition hashing
| * | Use MurmurHash2 for key partition hashingDana Powers2015-06-102-3/+98
| | |
* | | Merge pull request #399 from dpkp/refactor_simple_consumer_get_messagesDana Powers2015-06-101-29/+33
|\ \ \ | | | | | | | | Refactor SimpleConsumer get_messages and _fetch
| * | | Refactor SimpleConsumer get_messages and _fetchDana Powers2015-06-101-29/+33
| | | | | | | | | | | | | | | | | | | | - attempt to make these easier to read - add marginal retry logic to internal _fetch loop
* | | | Merge pull request #402 from dpkp/kafka_0_8_2_1Dana Powers2015-06-109-12/+181
|\ \ \ \ | |/ / / |/| | | Use kafka 0.8.2.1 in integration tests
| * | | Update to 0.8.2.1 compatibility in docsDana Powers2015-06-102-4/+4
| | | |
| * | | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-107-8/+177
| | | |
* | | | Merge pull request #405 from dpkp/log_error_typeDana Powers2015-06-102-7/+11
|\ \ \ \ | | | | | | | | | | Log response error types in consumer and producer logs
| * | | | Add error type to SimpleConsumer error loggingDana Powers2015-06-101-5/+8
| | | | |
| * | | | Log response error type in async producerDana Powers2015-06-101-2/+3
| | | | |
* | | | | Merge pull request #404 from dpkp/consumer_more_exception_handlingDana Powers2015-06-103-19/+79
|\ \ \ \ \ | |_|/ / / |/| | | | Consumer - handle exceptions in commit() and reset_partition_offset()
| * | | | Change SimpleConsumer.reset_partition_offset to return offset / None on ↵Dana Powers2015-06-101-5/+19
| | | | | | | | | | | | | | | | | | | | failure (dont raise exception)
| * | | | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵Dana Powers2015-06-101-1/+16
| | | | | | | | | | | | | | | | | | | | failure
| * | | | Change Consumer commit() to return True/False and log error; dont raise ↵Dana Powers2015-06-101-12/+18
| | | | | | | | | | | | | | | | | | | | client exceptions
| * | | | (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 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
| |
View Lorry Controller Status