| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
reconnects) (#799)
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
packets with TCP_NODELAY (#797)
|
|\
| |
| | |
Fixture auto ports
|
| | |
|
|/ |
|
|
|
|
| |
group test (#795)
|
|\
| |
| | |
Complete metrics instrumentation
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
|
|
|
| |
close (#792)
|
|\
| |
| |
| | |
Merge squashed branch 'larsjsol-sasl_plain'
|
| | |
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|
|
|
|
| |
add method ClusterMetadata.with_partitions
also fixup ClusterMetadata __str__
|
|\
| |
| | |
Vendor python module six; move selectors34 and socketpair under kafka.vendor
|
| | |
|
| | |
|
| | |
|
| | |
|
|/
|
| |
- also update internal classes RecordAccumulator and Sender
|
| |
|
|
|
|
| |
PR #750 added the code for passing along a password, but not any
documentation on it
|
|\
| |
| | |
Add client, base coordinator, and a few extra producer metrics.
|
| | |
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|