Merge pull request #27227 from loicmathieu/kafka-companion-confluent-…

…registry Add 'schema.registry.url' property to the Kafka Companion
quarkusio · Aug 10, 2022 · 2fe0ba5 · 2fe0ba5
2 parents 1609e8b + 50f2d3f
commit 2fe0ba5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...framework/kafka-companion/src/main/java/io/quarkus/test/kafka/KafkaCompanionResource.java b/...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));
             }
         }
     }