@Test public void shouldEnableSpecificAvroWhenSettingIsFalse() { Map<String, Object> config = new HashMap<>(); config.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, false); Map<String, Object> updatedConfig = ConfigurationUtils.withSpecificAvroEnabled(config); assertThat( (boolean) updatedConfig.get(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG), is(true)); }
public static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config) { Map<String, Object> specificAvroEnabledConfig = config == null ? new HashMap<String, Object>() : new HashMap<>(config); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); return specificAvroEnabledConfig; }
ConfigurationUtils { public static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config) { Map<String, Object> specificAvroEnabledConfig = config == null ? new HashMap<String, Object>() : new HashMap<>(config); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); return specificAvroEnabledConfig; } }
ConfigurationUtils { public static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config) { Map<String, Object> specificAvroEnabledConfig = config == null ? new HashMap<String, Object>() : new HashMap<>(config); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); return specificAvroEnabledConfig; } private  ConfigurationUtils(); }
ConfigurationUtils { public static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config) { Map<String, Object> specificAvroEnabledConfig = config == null ? new HashMap<String, Object>() : new HashMap<>(config); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); return specificAvroEnabledConfig; } private  ConfigurationUtils(); static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config); static Map<String, Object> withReflectionAvroEnabled(final Map<String, ?> config); }
ConfigurationUtils { public static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config) { Map<String, Object> specificAvroEnabledConfig = config == null ? new HashMap<String, Object>() : new HashMap<>(config); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); return specificAvroEnabledConfig; } private  ConfigurationUtils(); static Map<String, Object> withSpecificAvroEnabled(final Map<String, ?> config); static Map<String, Object> withReflectionAvroEnabled(final Map<String, ?> config);  }