class KafkaFuture implements Future<T> {

    public abstract T get() throws InterruptedException, ExecutionException@Override
    public abstract T get() throws InterruptedException, ExecutionException;

}