使用ksql创建一个新的kafka主题模式,其中包含来自现有kafka主题的新超级字段

mmvthczy  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(247)

问题是,我将使用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程序或者至少是它的一部分来创建这个新的模式吗?谢谢您

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题