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