| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
| |
|
| |
|
|\
| |
| | |
Use Metadata Request/Response v1 with 0.10+ brokers
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
|\ \
| | |
| | | |
Producer metrics + consumer/producer benchmark scripts
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| |/ |
|
|/ |
|
| |
|
| |
|
|
|
|
| |
* Dont wait for group join to enable AutoCommitTask if broker version < 0.9
* For zookeeper offset storage, set a "coordinator" with least_loaded_node
|
|
|
|
|
|
| |
- add error type to all KafkaErrors
- add args to BrokerResponseError
- drop description from BrokerResponseError
- fix bug logging errbacks as callbacks
|
| |
|
| |
|
|\
| |
| | |
Drop recursion in Fetcher _unpack_message_set
|
| | |
|
| | |
|
|/ |
|
|\
| |
| | |
Fix bug causing KafkaProducer to double-compress message batches
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|
|\
| |
| | |
Fix consumer iteration on compacted topics
|
| | |
|
|/ |
|
|
|
|
| |
cert chains (#750)
|
| |
|
| |
|
| |
|
|
|
|
| |
(#732)
|
|
|
|
|
| |
constructors (#647)
* allow client.check_version timeout to be set in Producer and Consumer constructors
|
| |
|
| |
|
| |
|
| |
|
| |
|