Merge pull request quarkusio#878 from Ladicek/apicurio-registry-avro

Use Apicurio Registry Avro extension in the Kafka Avro quickstart

Author: cescoffier

kafka-avro-schema-quickstart/pom.xml

@@ -46,17 +46,12 @@
         </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-avro</artifactId>
+            <artifactId>quarkus-apicurio-registry-avro</artifactId>
         </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-arc</artifactId>
         </dependency>
-        <dependency>
-            <groupId>io.apicurio</groupId>
-            <artifactId>apicurio-registry-serdes-avro-serde</artifactId>
-            <version>2.0.0.Final</version>
-        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-junit5</artifactId>

kafka-avro-schema-quickstart/src/main/resources/application.properties

@@ -1,15 +1,9 @@
-# set the URL of the Apicurio Schema Registry, a global setting shared between all Kafka producers and consumers
-mp.messaging.connector.smallrye-kafka.apicurio.registry.url=http://localhost:8081/apis/registry/v2
-
 # set the connector to use for the `movies` channel to smallrye-kafka
 mp.messaging.outgoing.movies.connector=smallrye-kafka
 
 # the name of the corresponding Kafka topic to `movies`
 mp.messaging.outgoing.movies.topic=movies
 
-# set the serializer for the `movies` channel to the Apicurio Avro Serializer
-mp.messaging.outgoing.movies.value.serializer=io.apicurio.registry.serde.avro.AvroKafkaSerializer
-
 # automatically register the schema with the registry, if not present
 mp.messaging.outgoing.movies.apicurio.registry.auto-register=true
 
@@ -19,15 +13,10 @@ mp.messaging.incoming.movies-from-kafka.connector=smallrye-kafka
 # set the topic name for the channel to `movies`
 mp.messaging.incoming.movies-from-kafka.topic=movies
 
-# set the deserializer for the `movies-from-kafka` channel to the Apicurio Avro Deserializer
-mp.messaging.incoming.movies-from-kafka.value.deserializer=io.apicurio.registry.serde.avro.AvroKafkaDeserializer
-
 # disable auto-commit, Reactive Messaging handles it itself
 mp.messaging.incoming.movies-from-kafka.enable.auto.commit=false
 
 mp.messaging.incoming.movies-from-kafka.auto.offset.reset=earliest
 mp.messaging.incoming.movies-from-kafka.apicurio.registry.use-specific-avro-reader=true
 
-# TODO: this should not be needed, but Avro does not seem to use the correct CL
-# This will also cause dev mode issues
-quarkus.test.flat-class-path=true
+%prod.mp.messaging.connector.smallrye-kafka.apicurio.registry.url=http://localhost:8081/apis/registry/v2

kafka-avro-schema-quickstart/src/test/java/org/acme/kafka/KafkaAndSchemaRegistryTestResource.java

@@ -1,6 +1,5 @@
 package org.acme.kafka;
 
-import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.common.http.TestHTTPResource;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
@@ -18,14 +17,11 @@
 import java.util.concurrent.Executors;
 
 import static io.restassured.RestAssured.given;
-import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static java.util.concurrent.TimeUnit.SECONDS;
 import static org.awaitility.Awaitility.await;
 import static org.hamcrest.MatcherAssert.assertThat;
 
 @QuarkusTest
-// register the class that sets up Testcontainers:
-@QuarkusTestResource(KafkaAndSchemaRegistryTestResource.class)
 public class MovieResourceTest {
 
     @TestHTTPResource("/consumed-movies")