@Test public void testMockUrl() { final KafkaAvroSerializer kafkaAvroSerializer = new KafkaAvroSerializer(); kafkaAvroSerializer.configure( singletonMap(AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "mock: false ); Assert.assertSame(MockSchemaRegistry.getClientForScope("asdf"), kafkaAvroSerializer.schemaRegistry); Assert.assertNotSame(MockSchemaRegistry.getClientForScope("qwer"), 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); }    }