| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
compressed messageset (#1239)
|
| |
|
| |
|
| |
|
|
|
|
| |
review issues
|
| |
|
| |
|
|
|
|
| |
and send in parallel.
|
| |
|
|
|
|
| |
* Added `max_bytes` option and FetchRequest_v3 usage.
* Add checks for versions above 0.10 based on ApiVersionResponse
|
| |
|
|
|
|
| |
KafkaConsumer (#860)
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
(#770 / #594)
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
(#732)
|
| |
|
|
|
|
| |
messagesets
|
|
|
| |
Fixes #665
|
| |
|
| |
|
| |
|
|\
| |
| | |
Small improvements to fetching logic
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
FetchResponses
|
| |
|
| |
|
| |
|