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

Class RequestFutureAdapter<F,T>

java.lang.Object

org.apache.kafka.clients.consumer.internals.RequestFutureAdapter<F,T>

Type Parameters:

F - Type to adapt from

T - Type to adapt to

Direct Known Subclasses:

AbstractCoordinator.CoordinatorResponseHandler

public abstract class RequestFutureAdapter<F,T>
extends Object

Adapt from a request future of one type to another.

Constructor Summary

Constructors

Constructor	Description
RequestFutureAdapter()

Method Summary

Modifier and Type	Method	Description
void	onFailure(RuntimeException e, RequestFuture<T> future)
abstract void	onSuccess(F value, RequestFuture<T> future)

Methods inherited from class java.lang.Object

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

Constructor Details

RequestFutureAdapter

public RequestFutureAdapter()

Method Details

onSuccess

public abstract void onSuccess(F value,
 RequestFuture<T> future)

onFailure

public void onFailure(RuntimeException e,
 RequestFuture<T> future)