use correct env and redpanda

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · May 6, 2024 · 48110e1 · 48110e1
1 parent 94fdcdd
commit 48110e1
Show file tree

Hide file tree

Showing 8 changed files with 10 additions and 10 deletions.
diff --git a/backwards-compat-tests/scripts/run_local.sh b/backwards-compat-tests/scripts/run_local.sh
@@ -25,8 +25,8 @@ full-without-monitoring:
     - use: compactor
     - use: kafka
       user-managed: true
-      address: kafka
-      port: 9093
+      address: message_queue
+      port: 29092
 EOF
 
 cat <<EOF > risedev-components.user.env

diff --git a/backwards-compat-tests/scripts/utils.sh b/backwards-compat-tests/scripts/utils.sh
@@ -78,15 +78,15 @@ check_version() {
 }
 
 create_kafka_topic() {
-  RPK_BROKERS=kafka:9093 \
+  RPK_BROKERS=message_queue:29092 \
   rpk topic create backwards_compat_test_kafka_source
 }
 
 insert_json_kafka() {
   local JSON=$1
 
   echo "$JSON" | \
-  RPK_BROKERS=kafka:9093 \
+  RPK_BROKERS=message_queue:29092 \
   rpk topic produce backwards_compat_test_kafka_source -f "%k,%v"
 }
 

diff --git a/backwards-compat-tests/slt/kafka/invalid_options/seed.slt b/backwards-compat-tests/slt/kafka/invalid_options/seed.slt
@@ -14,7 +14,7 @@ CREATE SOURCE IF NOT EXISTS kafka_source_with_invalid_option
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
  invalid_option='oops'
 ) FORMAT PLAIN ENCODE JSON;

diff --git a/backwards-compat-tests/slt/kafka/seed.slt b/backwards-compat-tests/slt/kafka/seed.slt
@@ -11,7 +11,7 @@ CREATE SOURCE IF NOT EXISTS kafka_source
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT PLAIN ENCODE JSON;
 

diff --git a/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt b/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt
@@ -11,6 +11,6 @@ CREATE TABLE IF NOT EXISTS kafka_table
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT UPSERT ENCODE JSON;
diff --git a/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt b/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt
@@ -13,6 +13,6 @@ INCLUDE key as _rw_key
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT UPSERT ENCODE JSON;
diff --git a/ci/workflows/main-cron.yml b/ci/workflows/main-cron.yml
@@ -654,7 +654,7 @@ steps:
       - "build"
     plugins:
       - docker-compose#v5.1.0:
-          run: rw-build-env
+          run: source-test-env
           config: ci/docker-compose.yml
           mount-buildkite-agent: true
       - ./ci/plugins/upload-failure-logs

diff --git a/ci/workflows/pull-request.yml b/ci/workflows/pull-request.yml
@@ -642,7 +642,7 @@ steps:
       - "build"
     plugins:
       - docker-compose#v5.1.0:
-          run: rw-build-env
+          run: source-test-env
           config: ci/docker-compose.yml
           mount-buildkite-agent: true
       - ./ci/plugins/upload-failure-logs