@SuppressWarnings("WeakerAccess")
    public void deleteTopic(final String topic) {
        log.debug("Deleting topic { name: {} }", topic);
        try (final Admin adminClient = createAdminClient()) {
            adminClient.deleteTopics(Collections.singletonList(topic)).all().get();
        } catch (final InterruptedException | ExecutionException e) {
            if (!(e.getCause() instanceof UnknownTopicOrPartitionException)) {
                throw new RuntimeException(e);
            }
        }
    }
Create a Kafka topic with the given parameters.

@param topic       The name of the topic.
@param partitions  The number of partitions for this topic.
@param replication The replication factor for (partitions of) this topic.
@param topicConfig Additional topic-level configuration settings.
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java