NetworkClientUtils

NetworkClientUtils is…​FIXME

sendAndReceive Static Method

ClientResponse sendAndReceive(
  KafkaClient client
  ClientRequest request
  Time time) throws IOException

sendAndReceive…​FIXME

Note
 sendAndReceive is used when…​FIXME

Waiting Until Connection to Broker Node is Ready — awaitReady Static Method

boolean awaitReady(
  KafkaClient client
  Node node
  Time time
  long timeoutMs) throws IOException

awaitReady…​FIXME

Note
 awaitReady is used when…​FIXME

isReady Static Method

boolean isReady(
  KafkaClient client,
  Node node,
  long currentTime)

isReady…​FIXME

Note
 isReady is used when…​FIXME

results matching ""

    No results matching ""