static Properties resolveConsumerProperties(Map<String, String> options, Object keySchema, Object valueSchema) {
        Properties properties = from(options);

        withSerdeConsumerProperties(true, options, keySchema, properties);
        withSerdeConsumerProperties(false, options, valueSchema, properties);

        return properties;
    }
@Test
    public void when_consumerProperties_preferredLocalParallelismPropertyIsDefined_then_itIsIgnored() {
        assertThat(resolveConsumerProperties(Map.of(OPTION_PREFERRED_LOCAL_PARALLELISM, "-1")))
                .containsExactlyEntriesOf(Map.of(KEY_DESERIALIZER, ByteArrayDeserializer.class.getCanonicalName()));
    }