Я пытаюсь использовать kafka topi c в формате avro, с десериализацией с использованием класса SpecificAvroSerde, где настроен URL-адрес схемы. Однако после обновления версии схемы Serdes ссылается на более старую версию, которая выдает ошибку Ошибка при получении схемы Avro для идентификатора 1 . Мой последний идентификатор схемы - 18. Я обновил свой класс дел [Заказ], а также основанный на последнем идентификаторе схемы.
Есть ли какая-либо конфигурация, доступная для указания использования в коде последней версии схемы по умолчанию.
Буду признателен за любую помощь. Спасибо.
implicit val specificAvroSerde: Serde[Order] = {
val orderSerde = new SpecificAvroSerde[Order]
val isKeySerde: Boolean = false
orderSerde.configure(Collections.singletonMap(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryUrl), isKeySerde)
orderSerde
}
implicit val consumer: Consumed[String, Order] = Consumed.`with`(Serdes.String, specificAvroSerde)