Description
org.apache.kafka.clients.consumer.internals.Fetcher
client.send(fetchTarget, request) .addListener(new RequestFutureListener<ClientResponse>() { @Override public void onSuccess(ClientResponse resp) { FetchResponse response = (FetchResponse) resp.responseBody();
Attachments
Issue Links
- links to