| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
| |
berkerpeksag/selectors34@6128e06
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
KafkaConsumer (#860)
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
| |
Fixes a bug where lookup was done only once for the whole life of the
process -- if a broker's IP changed, client couldn't reconnect.
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
* Check for requests that timeout without causing a socket read/write event
|
|
|
| |
type error
|
|\
| |
| | |
In Kafka 9, advertised.host.name was renamed to advertised.listeners
|
| |
| |
| | |
In Kafka 9, advertised.host.name was renamed to advertised.listeners
|
| | |
|