test

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Sep 6, 2024 · 1d85abf · 1d85abf
1 parent cd4414d
commit 1d85abf
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/e2e_test/source/basic/kafka.slt b/e2e_test/source/basic/kafka.slt
@@ -498,6 +498,16 @@ FORMAT DEBEZIUM ENCODE JSON (
   ignore_key = 'true'
 )
 
+statement error Payload column is only allowed when row encode is JSON, but got Bytes
+CREATE TABLE test_include_payload (a bytea)
+INCLUDE payload
+WITH (
+    connector = 'kafka',
+    topic = 'kafka_1_partition_topic',
+    properties.bootstrap.server = 'message_queue:29092',
+    scan.startup.mode = 'earliest'
+) FORMAT PLAIN ENCODE BYTES
+
 statement ok
 CREATE TABLE test_include_payload (v1 int, v2 varchar)
 INCLUDE payload