| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | | | | Errors -> Error typo | Oliver Jowett | 2015-07-20 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Treat KafkaUnavailableError like other errors. | Oliver Jowett | 2015-07-19 | 1 | -5/+10 | |
| | | |/ / | |/| | | ||||||
| * | | | | Merge pull request #432 from ecanzonieri/lower_logging_level_metadata | Dana Powers | 2015-08-24 | 1 | -2/+2 | |
| |\ \ \ \ | |/ / / |/| | | | Use debug logging level for metadata request | |||||
| | * | | | Use debug logging level for metadata request | Enrico Canzonieri | 2015-07-21 | 1 | -2/+2 | |
| |/ / / | ||||||
| * | | | Merge pull request #412 from haosdent/seek_absolute_offset | Dana Powers | 2015-06-20 | 2 | -17/+60 | |
| |\ \ \ | | | | | | | | | fix #410 SimpleConsumer cannot seek to an absolute offset. | |||||
| | * | | | fix #410 SimpleConsumer cannot seek to an absolute offset. | haosdent | 2015-06-20 | 2 | -17/+60 | |
| | | | | | ||||||
| * | | | | Merge pull request #415 from ecanzonieri/lower_logging_level | Dana Powers | 2015-06-19 | 2 | -2/+2 | |
| |\ \ \ \ | |/ / / |/| | | | Lower logging level on replica not available and commit | |||||
| | * | | | Lower logging level on replica not available and commit | Enrico Canzonieri | 2015-06-19 | 2 | -2/+2 | |
| |/ / / | ||||||
| * | | | Set development version until next release | Dana Powers | 2015-06-12 | 1 | -1/+1 | |
| | | | | ||||||
| * | | | Update docs to 0.9.4 as latest | Dana Powers | 2015-06-12 | 1 | -1/+1 | |
| | |/ |/| | ||||||
| * | | Release 0.9.4v0.9.4 | Dana Powers | 2015-06-12 | 2 | -3/+3 | |
| | | | ||||||
| * | | Update CHANGELOG for 0.9.4 | Dana Powers | 2015-06-11 | 1 | -0/+69 | |
| | | | ||||||
| * | | Update contributors list -- great community! | Dana Powers | 2015-06-11 | 1 | -2/+5 | |
| | | | ||||||
| * | | Add KafkaClient.topics property to get list of known topics | Dana Powers | 2015-06-11 | 1 | -0/+4 | |
| | | | ||||||
| * | | Some minor updates to usage docs | Dana Powers | 2015-06-11 | 1 | -35/+40 | |
| | | | ||||||
| * | | Fix reading version in docs/conf.py | Dana Powers | 2015-06-11 | 1 | -3/+2 | |
| | | | ||||||
| * | | Increase timeout and backoff when retrying spawn of test fixtures | Dana Powers | 2015-06-11 | 1 | -2/+16 | |
| | | | ||||||
| * | | Merge pull request #378 from dpkp/murmur2_hashed_partitioner | Dana Powers | 2015-06-10 | 2 | -3/+98 | |
| |\ \ | | | | | | | Use MurmurHash2 for key partition hashing | |||||
| | * | | Use MurmurHash2 for key partition hashing | Dana Powers | 2015-06-10 | 2 | -3/+98 | |
| | | | | ||||||
| * | | | Merge pull request #399 from dpkp/refactor_simple_consumer_get_messages | Dana Powers | 2015-06-10 | 1 | -29/+33 | |
| |\ \ \ | | | | | | | | | Refactor SimpleConsumer get_messages and _fetch | |||||
| | * | | | Refactor SimpleConsumer get_messages and _fetch | Dana Powers | 2015-06-10 | 1 | -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_1 | Dana Powers | 2015-06-10 | 9 | -12/+181 | |
| |\ \ \ \ | |/ / / |/| | | | Use kafka 0.8.2.1 in integration tests | |||||
| | * | | | Update to 0.8.2.1 compatibility in docs | Dana Powers | 2015-06-10 | 2 | -4/+4 | |
| | | | | | ||||||
| | * | | | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0 | Dana Powers | 2015-06-10 | 7 | -8/+177 | |
| | | | | | ||||||
| * | | | | Merge pull request #405 from dpkp/log_error_type | Dana Powers | 2015-06-10 | 2 | -7/+11 | |
| |\ \ \ \ | | | | | | | | | | | Log response error types in consumer and producer logs | |||||
| | * | | | | Add error type to SimpleConsumer error logging | Dana Powers | 2015-06-10 | 1 | -5/+8 | |
| | | | | | | ||||||
| | * | | | | Log response error type in async producer | Dana Powers | 2015-06-10 | 1 | -2/+3 | |
| | | | | | | ||||||
| * | | | | | Merge pull request #404 from dpkp/consumer_more_exception_handling | Dana Powers | 2015-06-10 | 3 | -19/+79 | |
| |\ \ \ \ \ | |_|/ / / |/| | | | | Consumer - handle exceptions in commit() and reset_partition_offset() | |||||
| | * | | | | Change SimpleConsumer.reset_partition_offset to return offset / None on ↵ | Dana Powers | 2015-06-10 | 1 | -5/+19 | |
| | | | | | | | | | | | | | | | | | | | | | failure (dont raise exception) | |||||
| | * | | | | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵ | Dana Powers | 2015-06-10 | 1 | -1/+16 | |
| | | | | | | | | | | | | | | | | | | | | | failure | |||||
| | * | | | | Change Consumer commit() to return True/False and log error; dont raise ↵ | Dana Powers | 2015-06-10 | 1 | -12/+18 | |
| | | | | | | | | | | | | | | | | | | | | | client exceptions | |||||
| | * | | | | (test) Consumer commit() should log errors and return True/False, not raise ↵ | Dana Powers | 2015-06-10 | 1 | -0/+24 | |
| | | | | | | | | | | | | | | | | | | | | | exceptions | |||||
| | * | | | | Split consumer test class between Simple and MultiProcess | Dana Powers | 2015-06-10 | 1 | -1/+2 | |
| | | | | | | ||||||
| * | | | | | Use 500ms zookeeper session timeout for integration tests - no network here, ↵ | Dana Powers | 2015-06-10 | 4 | -0/+12 | |
| | | | | | | | | | | | | | | | | | | | | | and our restarts are fast | |||||
| * | | | | | Use at_least=True when counting messages in leader failover tests | Dana Powers | 2015-06-10 | 1 | -1/+4 | |
| |/ / / / | ||||||
| * | | | | Retry failed messages in failover integration tests; use module logger | Dana Powers | 2015-06-10 | 1 | -12/+17 | |
| |/ / / | ||||||
| * | | | Remove 1 sec timeout on topic creation in client response ordering test | Dana Powers | 2015-06-10 | 1 | -2/+2 | |
| |/ / | ||||||
| * | | Merge pull request #403 from dpkp/client_request_response_ordering | Dana Powers | 2015-06-10 | 2 | -11/+51 | |
| |\ \ | | | | | | | Client request response ordering | |||||
| | * | | Fix KafkaClient request / response ordering | Dana Powers | 2015-06-10 | 1 | -10/+20 | |
| | | | | ||||||
| | * | | Add KafkaClient test to show that request / response ordering is broken | Dana Powers | 2015-06-10 | 1 | -1/+31 | |
| |/ / | ||||||
| * | | Reduce replica timeouts to 1sec for failover integration testing | Dana Powers | 2015-06-10 | 4 | -0/+16 | |
| | | | ||||||
| * | | Test failover integration with 3-brokers / replicas / partitions | Dana Powers | 2015-06-09 | 1 | -3/+3 | |
| |/ | ||||||
| * | Add send/receive debug logging to async producer | Dana Powers | 2015-06-09 | 1 | -8/+11 | |
| | | ||||||
| * | KafkaClient log new broker and topic metadata received as INFO | Dana Powers | 2015-06-09 | 1 | -2/+2 | |
| | | ||||||
| * | KafkaClient: log responses by requestId for debugging | Dana Powers | 2015-06-09 | 1 | -1/+4 | |
| | | ||||||
| * | KafkaClient: log requestId on ConnectionError instead of hexdump of request ↵ | Dana Powers | 2015-06-09 | 1 | -6/+5 | |
| | | | | | contents | |||||
| * | Add thread id to logging format to assist with debugging test failures | Dana Powers | 2015-06-09 | 1 | -0/+1 | |
| | | ||||||
| * | Reset kafka.conn logger level in tearDown | Dana Powers | 2015-06-09 | 1 | -0/+13 | |
| | | ||||||
| * | Merge pull request #398 from dpkp/kafka_consumer_failed_payloads | Dana Powers | 2015-06-09 | 1 | -37/+61 | |
| |\ | | | | | Kafka consumer failed payloads | |||||
| | * | KafkaConsumer style nits | Dana Powers | 2015-06-08 | 1 | -26/+48 | |
| | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |