class KafkaOperations implements AutoCloseable {

    public boolean removeTopic(final String topic) {
        try {
            final DeleteTopicsResult result = adminClient.deleteTopics(Collections.singletonList(topic));

            // Wait for the async request to process.
            result.all().get();

            // return true?
            return true;
        } catch (final ExecutionException e) {
            throw handleExecutionException(e);
        } catch (final InterruptedException exception) {
            // TODO Handle this
            throw new RuntimeException(exception.getMessage(), exception);
        }
    }

    public  KafkaOperations(final AdminClient adminClient, final KafkaConsumer<String, String> consumerClient);

}