| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
| |
|
| |
|
| |
|
| |
|
| |
|
|\ |
|
|/
|
|
| |
Fixes #641
|
| |
|
|\
| |
| | |
to squelch the __del issue
|
| | |
|
| | |
|
|\ \
| |/
|/| |
Metrics java port
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| | |
This adds the parent metrics instance to kafka consumer, which will
eventually be used to instrument everything under consumer. To start
I ported the java consumer coordinator metrics.
|
| | |
|
|/
|
|
|
| |
There is no straight translation for the JMX reporter into python,
so I'll do something else in a separate commit.
|
|\
| |
| | |
Support SSL connections
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
|/ |
|
|\
| |
| | |
Manage non-blocking I/O events with selectors module
|
| | |
|
|/ |
|
|\
| |
| | |
Use KafkaClient callback to manage BrokerConnection state changes
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| | |
callback
|
| | |
|
|/ |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|\
| |
| | |
Simplify connection logic
|
| | |
|
| | |
|
| | |
|
| | |
|