问题是,我将使用ksql将原始kafka主题模式更改为新的嵌套模式这是我当前的kafka主题模式和字段:
Kafka主题avro schemakafka主题字段
我想用两个新的超级字段创建一个新的模式,它们被命名为controlheader和header,根据下图newschema
问题是如何使用ksql创建包含新字段的嵌套模式?例如,对于controlheader部分,我尝试了这个方法,但没有成功(我得到空值):
create stream newschema ( controlheader struct < ConversationID integer >) with (KAFKA_TOPIC='TBL4_', VALUE_FORMAT='AVRO');
你能帮我写一个ksql程序或者至少是它的一部分来创建这个新的模式吗?谢谢您
暂无答案!
目前还没有任何答案,快来回答吧!