@Test
void createProducer() {

    Producer<byte[], byte[]> producer = this.producer.createProducer(new KafkaURI("localhost"));
    assertThat(producer).isNotNull();
    producer.close(Duration.ZERO);
}