NetworkClientUtils
is…FIXME
ClientResponse sendAndReceive(
KafkaClient client
ClientRequest request
Time time) throws IOException
sendAndReceive
…FIXME
Note
|
sendAndReceive is used when…FIXME
|
boolean awaitReady(
KafkaClient client
Node node
Time time
long timeoutMs) throws IOException
awaitReady
…FIXME
Note
|
awaitReady is used when…FIXME
|