@Test public void typical() throws Exception { assertThat(KafkaFutures.join(completedFuture("foo")), is("foo")); }
@SneakyThrows({ InterruptedException.class, ExecutionException.class }) static <T> T join(KafkaFuture<T> future) { return future.get(); }
KafkaFutures { @SneakyThrows({ InterruptedException.class, ExecutionException.class }) static <T> T join(KafkaFuture<T> future) { return future.get(); } }
KafkaFutures { @SneakyThrows({ InterruptedException.class, ExecutionException.class }) static <T> T join(KafkaFuture<T> future) { return future.get(); }  }
KafkaFutures { @SneakyThrows({ InterruptedException.class, ExecutionException.class }) static <T> T join(KafkaFuture<T> future) { return future.get(); }   }
KafkaFutures { @SneakyThrows({ InterruptedException.class, ExecutionException.class }) static <T> T join(KafkaFuture<T> future) { return future.get(); }    }