NetworkClientUtils

NetworkClientUtils is…​FIXME

sendAndReceive Method

static 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 Method

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

awaitReady…​FIXME

Note
awaitReady is used when…​FIXME

results matching ""

    No results matching ""