Kafka KSQL Stream Json(string)word的值

64jmpszr  于 2023-08-02  发布在  Apache
关注(0)|答案(1)|浏览(100)

我在题目中有这样的记录:

{“ACCOUNT_TYPE_KY”:“7”,“ADDED_BY”:“f_affina”,CDC_TIMESTAMP":{“string”:“2023-07-19T16:43:44.926000000000”}}

字符串
为什么我得到了这个(字符串)的值,我如何才能摆脱它,同时创建流和使用新的主题在连接器?
我已经创建了以下流:

CREATE STREAM CORTEX_TYPE (ACCOUNT_TYPE_KY VARCHAR KEY, ADDED_BY VARCHAR, } CDC_TIMESTAMP VARCHAR) WITH (KAFKA_TOPIC=‘arb.snpdh_CTX_ACCOUNT_TYPE’, VALUE_FORMAT=‘JSON’);

CREATE STREAM CORTEX_TYPE_STREAM WITH(VALUE_FORMAT=‘AVRO’) AS SELECT * FROM CORTEX_TYPE;


并在接收器连接器中使用了CORTEX_TYPE_STREAM,它可以工作,但字段CDC_TIMESTAMP的值为-->

string":"2023-07-19T16:43:44.926000000000


我只想要没有字符串的值。

1u4esq0p

1u4esq0p1#

你确定这些数据不是阿夫罗的吗类型string密钥来自JSON Avro编码-https://avro.apache.org/docs/1.11.1/specification/#json-encoding
你得到它是因为制片人寄来的; ksqlDB不会向现有主题中添加随机字段。您将需要调整生成器代码。

相关问题