@Test public void testMixedUrlsAreRejected() { final KafkaAvroSerializer kafkaAvroSerializer = new KafkaAvroSerializer(); try { kafkaAvroSerializer.configure( singletonMap(AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "mock: false ); fail(); } catch (final ConfigException e) { Assert.assertEquals( "Cannot mix mock and real urls for 'schema.registry.url'. Got: [mock: e.getMessage() ); } try { kafkaAvroSerializer.configure( singletonMap(AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http: false ); fail(); } catch (final ConfigException e) { Assert.assertEquals( "Cannot mix mock and real urls for 'schema.registry.url'. Got: [http: e.getMessage() ); } Assert.assertNull(kafkaAvroSerializer.schemaRegistry); }
protected void configure(KafkaAvroDeserializerConfig config) { configureClientProperties(config, new AvroSchemaProvider()); useSpecificAvroReader = config .getBoolean(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG); }
AbstractKafkaAvroDeserializer extends AbstractKafkaSchemaSerDe { protected void configure(KafkaAvroDeserializerConfig config) { configureClientProperties(config, new AvroSchemaProvider()); useSpecificAvroReader = config .getBoolean(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG); } }
AbstractKafkaAvroDeserializer extends AbstractKafkaSchemaSerDe { protected void configure(KafkaAvroDeserializerConfig config) { configureClientProperties(config, new AvroSchemaProvider()); useSpecificAvroReader = config .getBoolean(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG); }  }
AbstractKafkaAvroDeserializer extends AbstractKafkaSchemaSerDe { protected void configure(KafkaAvroDeserializerConfig config) { configureClientProperties(config, new AvroSchemaProvider()); useSpecificAvroReader = config .getBoolean(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG); }   }
AbstractKafkaAvroDeserializer extends AbstractKafkaSchemaSerDe { protected void configure(KafkaAvroDeserializerConfig config) { configureClientProperties(config, new AvroSchemaProvider()); useSpecificAvroReader = config .getBoolean(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG); }    }