From 1d85abf656739b6d4383c6a0fc0a399d8538f729 Mon Sep 17 00:00:00 2001
From: tabVersion <tabvision@bupt.icu>
Date: Fri, 6 Sep 2024 23:53:58 +0800
Subject: [PATCH] test

Signed-off-by: tabVersion <tabvision@bupt.icu>
---
 e2e_test/source/basic/kafka.slt | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/e2e_test/source/basic/kafka.slt b/e2e_test/source/basic/kafka.slt
index d5a1d630b941e..6326c48263db8 100644
--- 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