Kafka ksql字符串数组字段插入报错，如何正确使用该类型？

首先明确：完全可以用ARRAY<STRING>类型存储['music','sport']这类字符串数组数据，你的问题出在INSERT语句的数组构造语法不符合ksqlDB的要求。

错误原因 #

ksqlDB不支持直接用[]或()来构造数组，必须使用官方指定的数组构造语法。

正确的INSERT语句 #

使用ARRAY[]语法构造数组：

INSERT INTO users (userid, interests) VALUES ('user0001', ARRAY['music', 'sport']);

或者也可以使用ARRAY()函数形式：

INSERT INTO users (userid, interests) VALUES ('user0001', ARRAY('music', 'sport'));

验证说明 #

执行上述语句后，数据会被正确写入Kafka的users主题，以JSON格式存储，其中interests字段会被序列化为["music","sport"]，完全匹配你需要的数组格式。

内容的提问来源于stack exchange，提问作者alphanumeric