Как переопределить KafkaAvroDeserializerConfig.SPECIFIC_AVRO_VALUE_TYPE_CONFIG при использовании Quarkus с Kafka и реест

Как переопределить KafkaAvroDeserializerConfig.SPECIFIC_AVRO_VALUE_TYPE_CONFIG при использовании Quarkus с Kafka и реест ⇐ JAVA

1 сообщение • Страница 1 из 1

Anonymous

Как переопределить KafkaAvroDeserializerConfig.SPECIFIC_AVRO_VALUE_TYPE_CONFIG при использовании Quarkus с Kafka и реест

Цитата

Сообщение Anonymous » 17 окт 2024, 15:37

У нас есть проект Quarkus, который использует Apache Kafka с реестром схем Confluent и Avro.
Он использует механизм генерации кода Quarkus для создания файлов Java из схемы Avro и использует определенную тему Kafka. >
Производитель этой темы внес изменение пространства имен в схему Avro. Это вызвало исключение десериализации в нашем потребительском приложении.

Код: Выделить всё

Could not find class X specified in writer's schema whilst finding reader's schema for a SpecificRecord.

Я знаю, что это проблема, специфичная для Java, из-за способа создания классов. Мои коллеги, использующие Scala, переопределили KafkaAvroDeserializerConfig.SPECIFIC_AVRO_VALUE_TYPE_CONFIG, чтобы решить эту проблему.
Можно ли переопределить эту конфигурацию в Quarkus/smallrye?
Что-то вроде mp.messaging.incoming. [channel].specific.avro.value.type?
Должен ли я по-прежнему устанавливать mp.messaging.incoming.[channel].specific.avro.reader true?
Есть ли другой способ решения этой проблемы?
Я пробовал использовать псевдоним в схеме чтения, но У меня все еще есть то же исключение. Я также попробовал «установить» mp.messaging.incoming.[channel].specific.avro.value.type, но не был уверен, существует ли это свойство на самом деле, и все равно получил то же исключение.

Подробнее здесь: https://stackoverflow.com/questions/790 ... onfig-when

1729168636

Anonymous

У нас есть проект Quarkus, который использует Apache Kafka с реестром схем Confluent и Avro.
Он использует механизм генерации кода Quarkus для создания файлов Java из схемы Avro и использует определенную тему Kafka. >
Производитель этой темы внес изменение пространства имен в схему Avro. Это вызвало исключение десериализации в нашем потребительском приложении.
[code]Could not find class X specified in writer's schema whilst finding reader's schema for a SpecificRecord.[/code]
Я знаю, что это проблема, специфичная для Java, из-за способа создания классов. Мои коллеги, использующие Scala, переопределили KafkaAvroDeserializerConfig.SPECIFIC_AVRO_VALUE_TYPE_CONFIG, чтобы решить эту проблему.
Можно ли переопределить эту конфигурацию в Quarkus/smallrye?
Что-то вроде mp.messaging.incoming. [channel].specific.avro.value.type?
Должен ли я по-прежнему устанавливать mp.messaging.incoming.[channel].specific.avro.reader true?
Есть ли другой способ решения этой проблемы?
Я пробовал использовать псевдоним в схеме чтения, но У меня все еще есть то же исключение. Я также попробовал «установить» mp.messaging.incoming.[channel].specific.avro.value.type, но не был уверен, существует ли это свойство на самом деле, и все равно получил то же исключение. 

Подробнее здесь: [url]https://stackoverflow.com/questions/79098110/how-to-override-kafkaavrodeserializerconfig-specific-avro-value-type-config-when[/url]