当我尝试在KSQL中使用PARTITION BY时,PARTITION BY使用的字段将在值中丢失
我有一个主题test_partition_key_stream,它的模式如下:value:key:null{"id":1,"age":18,"name":"lisa"}然后我这样做了:CREATESTREAMTEST_STREAM_JSON(idINT,ageINT,nameVARCHAR)WITH(KAFKA_TOPIC='test_partition_key_stream',VALUE_FOR