| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Add error 104 / Connection reset by peer to expected check_version errors | Dana Powers | 2016-01-25 | 1 | -2/+2 | |
| | | ||||||
| * | Small KafkaClient.check_version() improvements | Dana Powers | 2016-01-25 | 1 | -3/+20 | |
| | | | | | | - filter connection failure logging during version check - raise UnrecognizedBrokerVersion if we cant id broker | |||||
| * | Log new KafkaClient under kafka.client until files are merged | Dana Powers | 2016-01-25 | 1 | -1/+1 | |
| | | ||||||
| * | Write bytes to wake_fd | Dana Powers | 2016-01-24 | 1 | -1/+1 | |
| | | ||||||
| * | KafkaClient.add_topic() -- for use by async producer | Dana Powers | 2016-01-23 | 1 | -0/+15 | |
| | | ||||||
| * | Optionally sleep in KafkaClient.poll(), add KafkaClient.wakeup() | Dana Powers | 2016-01-23 | 1 | -7/+37 | |
| | | ||||||
| * | Add back connection_delay method to KafkaClient - used by KafkaProducer | Dana Powers | 2016-01-18 | 1 | -0/+20 | |
| | | | | | This reverts commit 88cf1b5e4551cd96322aa812fa482bf0f978060a. | |||||
| * | Remove sleep call in client.poll -- expect callers to manage this and log ↵ | Dana Powers | 2016-01-12 | 1 | -6/+5 | |
| | | | | | warning | |||||
| * | Receive all available responses in client._poll | Dana Powers | 2016-01-10 | 1 | -3/+4 | |
| | | ||||||
| * | If a completed future is polled, do not block | Dana Powers | 2016-01-10 | 1 | -6/+13 | |
| | | ||||||
| * | Avoid CPU spinnning when there are no sockets to read | Dana Powers | 2016-01-10 | 1 | -0/+8 | |
| | | ||||||
| * | Fix delayed_task timeout commit 45d26b6 | Dana Powers | 2016-01-10 | 1 | -5/+6 | |
| | | ||||||
| * | Check delayed task timeout in client.poll() | Dana Powers | 2016-01-10 | 1 | -2/+4 | |
| | | ||||||
| * | Refresh metadata on failed connection attemptshandle_disconnect | Dana Powers | 2016-01-09 | 1 | -0/+5 | |
| | | ||||||
| * | Add metadata_max_age_ms and retry_backoff_ms options to async client | Dana Powers | 2016-01-07 | 1 | -0/+8 | |
| | | ||||||
| * | Fix future redefine bug in client.poll | Dana Powers | 2016-01-04 | 1 | -3/+3 | |
| | | ||||||
| * | Catch py3 ConnectionErrors | Dana Powers | 2016-01-03 | 1 | -3/+9 | |
| | | ||||||
| * | Add KafkaClient.check_version() to guess broker version | Dana Powers | 2016-01-03 | 1 | -0/+52 | |
| | | ||||||
| * | Fix bug in _initiate_connect preventing reconnect to 'bootstrap' | Dana Powers | 2016-01-03 | 1 | -3/+3 | |
| | | ||||||
| * | sys.maxint not supported in python3 | Dana Powers | 2016-01-01 | 1 | -4/+3 | |
| | | ||||||
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -7/+7 | |
| | | ||||||
| * | More Docstring Improvements | Dana Powers | 2015-12-30 | 1 | -60/+131 | |
| | | ||||||
| * | Fix blacked_out typo in least_loaded_node | Dana Powers | 2015-12-30 | 1 | -1/+1 | |
| | | ||||||
| * | Rename KafkaClient.connection_failed -> is_disconnected | Dana Powers | 2015-12-30 | 1 | -1/+1 | |
| | | ||||||
| * | Improve removed tasks handing in DelayedTaskQueue.pop_ready | Dana Powers | 2015-12-30 | 1 | -2/+5 | |
| | | ||||||
| * | Remove unnecessary calls in KafkaClient._poll | Dana Powers | 2015-12-30 | 1 | -13/+13 | |
| | | | | | | - Dont process connections; outer poll() loop does this now - Only recv connections that select says are readable | |||||
| * | Resolve delayed task futures in KafkaClient.poll | Dana Powers | 2015-12-30 | 1 | -3/+6 | |
| | | ||||||
| * | Remove unused connection_delay method from KafkaClient | Dana Powers | 2015-12-30 | 1 | -18/+0 | |
| | | ||||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -44/+29 | |
| | | ||||||
| * | New async KafkaClient, based on java NetworkClient and ConsumerClient | Dana Powers | 2015-12-28 | 1 | -0/+502 | |
| - Support async client bootstrap retries after exponential backoff - Attempt to finish_connect if still connecting in KafkaClient.ready(node_id) - Run full async loop while waiting for futures in KafkaClient.poll() - Add more fallbacks to KafkaClient.least_loaded_node; worst case, retry boostrap | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |