summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Release 0.9.4v0.9.4Dana Powers2015-06-122-3/+3
* Update CHANGELOG for 0.9.4Dana Powers2015-06-111-0/+69
* Update contributors list -- great community!Dana Powers2015-06-111-2/+5
* Add KafkaClient.topics property to get list of known topicsDana Powers2015-06-111-0/+4
* Some minor updates to usage docsDana Powers2015-06-111-35/+40
* Fix reading version in docs/conf.pyDana Powers2015-06-111-3/+2
* 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 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 _fetchDana Powers2015-06-101-29/+33
* | | Merge pull request #402 from dpkp/kafka_0_8_2_1Dana Powers2015-06-109-12/+181
|\ \ \ | |/ / |/| |
| * | 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
| |/
View Lorry Controller Status