| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
| |
|
|\
| |
| | |
KafkaProducer
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|
|
|
|
| |
errors on python 2.7
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
This reverts commit 88cf1b5e4551cd96322aa812fa482bf0f978060a.
|
|\
| |
| | |
Add DeprecationWarnings to legacy classes
|
| |
| |
| |
| | |
and KafkaConnection
|
|\ \
| |/
|/| |
Improve iterator fetch requests
|
| |
| |
| |
| | |
poll if no in-flight fetches
|
| |
| |
| |
| | |
warning
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| | |
Generally should not init_fetches while the generator has pending
messages; this revision adds an explicit check / noop to the
public interface, and uses a private method internally to
attempt to pipeline fetch requests.
|
| | |
|
| | |
|
|/
|
|
| |
travis logs)
|
|\
| |
| | |
Prevent idle CPU spin by sleeping if there are no sockets to read
|
| |
| |
| |
| | |
iterating fetcher
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
|\
| |
| | |
Add delayed task timeouts to _poll calls
|
| |
| |
| |
| |
| |
| | |
- Consider all delayed tasks, not just heartbeat
- Include metadata update timeout
- Fix second / millisecond bug calling client.poll()
|
| | |
|