@Test
public void rejectConnectionWithInvalidNormalizerMapperJsonFieldSelector() {

    final Map<String, String> normalizerMessageMapperOptions = new HashMap<>();
    normalizerMessageMapperOptions.put(NormalizedMessageMapper.FIELDS, "foo(bar");
    final Connection connection =
            ConnectivityModelFactory.newConnectionBuilder(CONNECTION_ID,
                    ConnectionType.AMQP_10, ConnectivityStatus.OPEN, "amqp://localhost:5671")
                    .targets(TestConstants.Targets.TARGETS)
                    .mappingContext(ConnectivityModelFactory.newMappingContext(
                            NormalizedMessageMapper.class.getName(),
                            normalizerMessageMapperOptions
                    ))
                    .build();
    final ConnectionValidator underTest = getConnectionValidator();
    assertThatExceptionOfType(ConnectionConfigurationInvalidException.class)
            .isThrownBy(() -> underTest.validate(connection, DittoHeaders.empty(), actorSystem));
}