Quarkus Kafka Streams Extension with Apicurio Registry and Avro SerDes

[ngc4579]

Hi,

how are the quarkus.kafka-streams.schema-registry-key and quarkus.kafka-streams.schema-registry-url configuration properties supposed to work in conjunction with a Quarkus Kafka Streams application and Avro SerDes (using an Apicurio registry)?

Specifically: when building a Topology, how do I construct the necessary Avro SerDes? Do I have to specifiy the registry URL while configuring the SerDes in code, or is there some 'magic' behind the scenes that allows me to use Avro SerDes while using the configuration properties mentioned above?

This doesn't work:

    @Produces
    public Topology buildTopology() {

        final StreamsBuilder streamsBuilder = new StreamsBuilder();

        Serde<Long> agencyKeySerde = new AvroSerde<>(Long.class);
        Serde<Agency> agencySerde = new AvroSerde<>(Agency.class);
        ...

When running this with the following configuration:

quarkus.kafka-streams.schema-registry-key=apicurio.registry.url
quarkus.kafka-streams.schema-registry-url=http://<redacted>

... the application dies at startup complaining that no apicurio.registry.url is defined.

[quarkus-bot[bot]]

/cc @alesj (kafka,kafka-streams), @cescoffier (kafka), @gunnarmorling (kafka-streams), @ozangunalp (kafka,kafka-streams), @rquinio (kafka-streams)