From a7fccea74aa94b10e68d28089c72a8aca295b502 Mon Sep 17 00:00:00 2001
From: Xiangjin <xiangjin@risingwave-labs.com>
Date: Wed, 11 Sep 2024 15:40:19 +0800
Subject: [PATCH] control substitution on

---
 .../source_inline/kafka/protobuf/recover.slt  | 20 +++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/e2e_test/source_inline/kafka/protobuf/recover.slt b/e2e_test/source_inline/kafka/protobuf/recover.slt
index 03e8f6f83bcff..3babf26793f2a 100644
--- a/e2e_test/source_inline/kafka/protobuf/recover.slt
+++ b/e2e_test/source_inline/kafka/protobuf/recover.slt
@@ -1,9 +1,11 @@
+control substitution on
+
 system ok
 rpk topic create 'test-pb-struct'
 
 
 system ok
-jq -sR '{"schema":.,"schemaType":"PROTOBUF"}' << EOF | curl -X POST -H 'content-type: application/json' -d @- 'http://schemaregistry:8082/subjects/test-pb-struct-value/versions'
+jq -sR '{"schema":.,"schemaType":"PROTOBUF"}' << EOF | curl -X POST -H 'content-type: application/json' -d @- "${RISEDEV_SCHEMA_REGISTRY_URL}/subjects/test-pb-struct-value/versions"
 syntax = "proto3";
 package test;
 message User {
@@ -20,17 +22,16 @@ EOF
 # create a source with v1 schema
 statement ok
 create source s with (
-  connector = 'kafka',
-  properties.bootstrap.server = 'message_queue:29092',
+  ${RISEDEV_KAFKA_WITH_OPTIONS_COMMON},
   topic = 'test-pb-struct')
 format plain encode protobuf (
-  schema.registry = 'http://schemaregistry:8082',
+  schema.registry = '${RISEDEV_SCHEMA_REGISTRY_URL}',
   message = 'test.User');
 
 
 # register a v2 schema
 system ok
-jq -sR '{"schema":.,"schemaType":"PROTOBUF"}' << EOF | curl -X POST -H 'content-type: application/json' -d @- 'http://schemaregistry:8082/subjects/test-pb-struct-value/versions'
+jq -sR '{"schema":.,"schemaType":"PROTOBUF"}' << EOF | curl -X POST -H 'content-type: application/json' -d @- "${RISEDEV_SCHEMA_REGISTRY_URL}/subjects/test-pb-struct-value/versions"
 syntax = "proto3";
 package test;
 message User {
@@ -59,11 +60,10 @@ create sink sk as select
   1 as id,
   row('Alan', 'Turing', 'Mathison')::struct<first_name varchar, last_name varchar, middle_name varchar> as name
 with (
-  connector = 'kafka',
-  properties.bootstrap.server = 'message_queue:29092',
+  ${RISEDEV_KAFKA_WITH_OPTIONS_COMMON},
   topic = 'test-pb-struct')
 format plain encode protobuf (
-  schema.registry = 'http://schemaregistry:8082',
+  schema.registry = '${RISEDEV_SCHEMA_REGISTRY_URL}',
   message = 'test.User');
 
 
@@ -86,11 +86,11 @@ drop source s;
 
 
 system ok
-curl -X DELETE 'http://schemaregistry:8082/subjects/test-pb-struct-value'
+curl -X DELETE "${RISEDEV_SCHEMA_REGISTRY_URL}/subjects/test-pb-struct-value"
 
 
 system ok
-curl -X DELETE 'http://schemaregistry:8082/subjects/test-pb-struct-value?permanent=true'
+curl -X DELETE "${RISEDEV_SCHEMA_REGISTRY_URL}/subjects/test-pb-struct-value?permanent=true"
 
 
 system ok