我在题目中有这样的记录:
{“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
型
我只想要没有字符串的值。
1条答案
按热度按时间1u4esq0p1#
你确定这些数据不是阿夫罗的吗类型
string
密钥来自JSON Avro编码-https://avro.apache.org/docs/1.11.1/specification/#json-encoding你得到它是因为制片人寄来的; ksqlDB不会向现有主题中添加随机字段。您将需要调整生成器代码。