public interface BlockingSend
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
initiateClose() |
org.apache.kafka.clients.ClientResponse |
sendRequest(org.apache.kafka.common.requests.AbstractRequest.Builder<? extends org.apache.kafka.common.requests.AbstractRequest> requestBuilder) |
org.apache.kafka.clients.ClientResponse sendRequest(org.apache.kafka.common.requests.AbstractRequest.Builder<? extends org.apache.kafka.common.requests.AbstractRequest> requestBuilder) throws IOException
IOException
void initiateClose()