add include clause

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Jun 3, 2024 · 914bdc5 · 914bdc5
1 parent 1997b33
commit 914bdc5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/e2e_test/source_inline/kafka/avro/name_strategy.slt b/e2e_test/source_inline/kafka/avro/name_strategy.slt
@@ -40,6 +40,7 @@ statement ok
 CREATE TABLE upsert_avro_json (
   PRIMARY KEY("ID")
 )
+INCLUDE KEY AS "ID"
 WITH (
   connector = 'kafka',
   properties.bootstrap.server = '${RISEDEV_KAFKA_BOOTSTRAP_SERVERS}',