@Test public void test_schemas_per_subject() { HashMap<String, String> props = new HashMap<>(); props.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "bogus"); props.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, "true"); props.put(AbstractKafkaSchemaSerDeConfig.MAX_SCHEMAS_PER_SUBJECT_CONFIG, "5"); avroSerializer.configure(props, false); }
@Override public void configure(Map<String, ?> configs, boolean isKey) { this.isKey = isKey; configure(new KafkaAvroSerializerConfig(configs)); }
KafkaAvroSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object> { @Override public void configure(Map<String, ?> configs, boolean isKey) { this.isKey = isKey; configure(new KafkaAvroSerializerConfig(configs)); } }
KafkaAvroSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object> { @Override public void configure(Map<String, ?> configs, boolean isKey) { this.isKey = isKey; configure(new KafkaAvroSerializerConfig(configs)); } KafkaAvroSerializer();  KafkaAvroSerializer(SchemaRegistryClient client);  KafkaAvroSerializer(SchemaRegistryClient client, Map<String, ?> props); }
KafkaAvroSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object> { @Override public void configure(Map<String, ?> configs, boolean isKey) { this.isKey = isKey; configure(new KafkaAvroSerializerConfig(configs)); } KafkaAvroSerializer();  KafkaAvroSerializer(SchemaRegistryClient client);  KafkaAvroSerializer(SchemaRegistryClient client, Map<String, ?> props); @Override void configure(Map<String, ?> configs, boolean isKey); @Override byte[] serialize(String topic, Object record); @Override void close(); }
KafkaAvroSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object> { @Override public void configure(Map<String, ?> configs, boolean isKey) { this.isKey = isKey; configure(new KafkaAvroSerializerConfig(configs)); } KafkaAvroSerializer();  KafkaAvroSerializer(SchemaRegistryClient client);  KafkaAvroSerializer(SchemaRegistryClient client, Map<String, ?> props); @Override void configure(Map<String, ?> configs, boolean isKey); @Override byte[] serialize(String topic, Object record); @Override void close();  }