Package org.apache.kafka.clients.consumer.internals

Class NetworkClientDelegate.FutureCompletionHandler

java.lang.Object

org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.FutureCompletionHandler

All Implemented Interfaces:

org.apache.kafka.clients.RequestCompletionHandler

Enclosing class:

NetworkClientDelegate

public static class NetworkClientDelegate.FutureCompletionHandler
extends Object
implements org.apache.kafka.clients.RequestCompletionHandler

Method Summary

Modifier and Type	Method	Description
long	completionTimeMs()
CompletableFuture<org.apache.kafka.clients.ClientResponse>	future()
void	onComplete(org.apache.kafka.clients.ClientResponse response)
void	onFailure(long currentTimeMs, RuntimeException e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

onFailure

public void onFailure(long currentTimeMs,
 RuntimeException e)

completionTimeMs

public long completionTimeMs()

onComplete

public void onComplete(org.apache.kafka.clients.ClientResponse response)

Specified by:

onComplete in interface org.apache.kafka.clients.RequestCompletionHandler

future

public CompletableFuture<org.apache.kafka.clients.ClientResponse> future()