@Test
public void invalidPartitionThrowsError() {

    assertThatExceptionOfType(ConnectionConfigurationInvalidException.class)
            .isThrownBy(() -> KafkaPublishTarget.fromTargetAddress("events#notAnInteger"));
}