summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * | | 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
|\ \ \ \
| * | | | 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
|\ \ \ \ \ | |_|/ / / |/| | | |
| * | | | Change SimpleConsumer.reset_partition_offset to return offset / None on failu...Dana Powers2015-06-101-5/+19
| * | | | (test) SimpleConsumer.reset_partition_offset should not raise exception on fa...Dana Powers2015-06-101-1/+16
| * | | | Change Consumer commit() to return True/False and log error; dont raise clien...Dana Powers2015-06-101-12/+18
| * | | | (test) Consumer commit() should log errors and return True/False, not raise e...Dana Powers2015-06-101-0/+24
| * | | | 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
* | | | | 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
|\ \
| * | 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 c...Dana Powers2015-06-091-6/+5
* 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
|\
| * 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
|\ \
| * | 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
|\ \
| * | 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
|\ \ | |/ |/|
| * Use a list, not request_tries.keys(), to track requests / responses in async ...Dana Powers2015-06-091-2/+4
| * Add Unit test for async producer leader change; return ProduceResponse on suc...Dana Powers2015-06-091-10/+56
|/
* Merge pull request #394 from dpkp/cleanupsDana Powers2015-06-088-152/+88
|\
| * 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
| * 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
View Lorry Controller Status