update e2e

risingwavelabs · Jul 22, 2024 · d0a4c93 · d0a4c93
1 parent 6c58cb2
commit d0a4c93
Showing 1 changed file with 1 addition and 13 deletions.
diff --git a/e2e_test/source_inline/kafka/avro/name_strategy.slt b/e2e_test/source_inline/kafka/avro/name_strategy.slt
@@ -84,17 +84,6 @@ python3 scripts/source/schema_registry_producer.py  "${RISEDEV_KAFKA_BOOTSTRAP_S
 
 
 
-statement error SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY expect non-empty field key\.message
-create table t_topic_record () with (
-    connector = 'kafka',
-    topic = 'upsert_avro_json-topic-record',
-    properties.bootstrap.server = '${RISEDEV_KAFKA_BOOTSTRAP_SERVERS}'
-) format upsert encode avro (
-    schema.registry = '${RISEDEV_SCHEMA_REGISTRY_URL}',
-    schema.registry.name.strategy = 'topic_record_name_strategy',
-    message = 'CPLM.OBJ_ATTRIBUTE_VALUE'
-);
-
 statement ok
 create table t_topic_record (primary key(rw_key))
 INCLUDE KEY AS rw_key
@@ -105,8 +94,7 @@ with (
 ) format upsert encode avro (
     schema.registry = '${RISEDEV_SCHEMA_REGISTRY_URL}',
     schema.registry.name.strategy = 'topic_record_name_strategy',
-    message = 'CPLM.OBJ_ATTRIBUTE_VALUE',
-    key.message = 'string'
+    message = 'CPLM.OBJ_ATTRIBUTE_VALUE'
 );