From a632761c91d4cfde12ab912b84d2c523ea2b7786 Mon Sep 17 00:00:00 2001 From: Carles Arnal Date: Wed, 31 Jan 2024 11:49:11 +0100 Subject: [PATCH] Add protobuf native integration tests for apicurio serdes support --- .../quarkus/it/kafka/KafkaJsonSchemaIT.java | 28 +++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 integration-tests/kafka-protobuf-apicurio2/src/test/java/io/quarkus/it/kafka/KafkaJsonSchemaIT.java diff --git a/integration-tests/kafka-protobuf-apicurio2/src/test/java/io/quarkus/it/kafka/KafkaJsonSchemaIT.java b/integration-tests/kafka-protobuf-apicurio2/src/test/java/io/quarkus/it/kafka/KafkaJsonSchemaIT.java new file mode 100644 index 0000000000000..6a7d91d84dc1c --- /dev/null +++ b/integration-tests/kafka-protobuf-apicurio2/src/test/java/io/quarkus/it/kafka/KafkaJsonSchemaIT.java @@ -0,0 +1,28 @@ +package io.quarkus.it.kafka; + +import io.apicurio.registry.rest.client.RegistryClientFactory; +import io.apicurio.rest.client.VertxHttpClientProvider; +import io.quarkus.it.kafka.protobuf.ProtobufKafkaCreator; +import io.quarkus.test.common.QuarkusTestResource; +import io.quarkus.test.junit.QuarkusIntegrationTest; +import io.vertx.core.Vertx; +import org.junit.jupiter.api.BeforeAll; + +@QuarkusIntegrationTest +@QuarkusTestResource(value = KafkaResource.class, restrictToAnnotatedClass = true) +public class KafkaJsonSchemaIT extends KafkaProtobufTestBase { + + ProtobufKafkaCreator creator; + + @Override + ProtobufKafkaCreator creator() { + return creator; + } + + @BeforeAll + public static void setUp() { + // this is for the test JVM, which also uses Kafka client, which in turn also interacts with the registry + RegistryClientFactory.setProvider(new VertxHttpClientProvider(Vertx.vertx())); + } + +}