    @Test
    public void createsSnsTopicWhenProvisionsProducer() {

        ExtendedProducerProperties<SqsProducerProperties> producerProperties = new ExtendedProducerProperties<>(new SqsProducerProperties());

        sqsStreamProvisioner.provisionProducerDestination("topic-name", producerProperties);

        List<String> topicArns = listTopicsArns();
        assertThat(topicArns).hasSize(1);
        assertThat(sns.getTopicAttributes(topicArns.get(0)).getAttributes().get("TopicArn")).endsWith("topic-name");
    }