[kafka] [apicurio] - ClassNotFoundException in dev mode with specific artifact resolver

[SamyLegal]

Hi,

I develop an application with Quarkus that consume messages from Kafka encoded in Avro format.
I use the library "quarkus-smallrye-reactive-messaging-kafka" for this.

By default, in the "smallrye" library, the strategy for found the schema in the schema registry for deserialize my message is based on the topic name.
For information the namespace of the default strategy class is "io.apicurio.registry.serde.strategy.TopicIdStrategy".

When i define another class for the strategy like this one "io.apicurio.registry.serde.avro.strategy.RecordIdStrategy", i have an error of Quarkus saying that it does not found the class.

Stacktrace of the error

Caused by: java.lang.ClassNotFoundException: "io.apicurio.registry.serde.avro.strategy.RecordIdStrategy"
        at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
        at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
        at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526)
        at io.quarkus.bootstrap.classloading.QuarkusClassLoader.loadClass(QuarkusClassLoader.java:518)
        at io.quarkus.bootstrap.classloading.QuarkusClassLoader.loadClass(QuarkusClassLoader.java:468)
        at io.quarkus.bootstrap.classloading.QuarkusClassLoader.loadClass(QuarkusClassLoader.java:518)
        at io.quarkus.bootstrap.classloading.QuarkusClassLoader.loadClass(QuarkusClassLoader.java:468)
        at java.base/java.lang.Class.forName0(Native Method)
        at java.base/java.lang.Class.forName(Class.java:421)
        at java.base/java.lang.Class.forName(Class.java:412)
        at io.apicurio.registry.resolver.utils.Utils.loadClass(Utils.java:33)

Configuration of my channel for this configuration.

mp.messaging.incoming.$channel.apicurio.registry.artifact-resolver-strategy="io.apicurio.registry.serde.avro.strategy.RecordIdStrategy"

I have this error when i am in dev mode with command quarkus dev.
My version of Quarkus is 3.6.3.

I have the same error if a define a custom serializer like this in my application.properties

mp.messaging.incoming.pieces.key.deserializer=org.apache.kafka.common.serialization.StringSerializer

Have you got an idea of the origine of this error ?

Thank you

[quarkus-bot[bot]]

/cc @alesj (kafka), @cescoffier (kafka), @ozangunalp (kafka)

[ozangunalp]

I believe you need to remove the quotes from FQCN.

[SamyLegal]

Thank you for your answer.

Exactly it works. Thanks