@Test
public void invalidCharsInTopicNameThrowError() {

    assertThatExceptionOfType(ConnectionConfigurationInvalidException.class)
            .isThrownBy(() -> KafkaPublishTarget.fromTargetAddress("events*andstuff"));
}