From 50f2d3f1bd14b0b8f518d8d346422e0dc7199898 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Wed, 10 Aug 2022 15:32:09 +0200 Subject: [PATCH] Add 'schema.registry.url' property to the Kafka Companion. This allow it to be compatible with Confluent Schema Registry --- .../java/io/quarkus/test/kafka/KafkaCompanionResource.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/test-framework/kafka-companion/src/main/java/io/quarkus/test/kafka/KafkaCompanionResource.java b/test-framework/kafka-companion/src/main/java/io/quarkus/test/kafka/KafkaCompanionResource.java index 9e8f97764e9ad..370e2e5677c49 100644 --- a/test-framework/kafka-companion/src/main/java/io/quarkus/test/kafka/KafkaCompanionResource.java +++ b/test-framework/kafka-companion/src/main/java/io/quarkus/test/kafka/KafkaCompanionResource.java @@ -32,9 +32,12 @@ public void setIntegrationTestContext(DevServicesContext context) { kafkaCompanion = new KafkaCompanion(bootstrapServers); String apicurioUrl = devServicesProperties.get("mp.messaging.connector.smallrye-kafka.apicurio.registry.url"); if (apicurioUrl != null) { + // normally, the processor will set both property so it's safe to unconditionally load the confluent URL + String confluentUrl = devServicesProperties.get("mp.messaging.connector.smallrye-kafka.schema.registry.url"); kafkaCompanion.setCommonClientConfig(Map.of( "apicurio.registry.url", apicurioUrl, - "apicurio.registry.auto-register", "true")); + "apicurio.registry.auto-register", "true", + "schema.registry.url", confluentUrl)); } } }