当我尝试在KSQL中使用PARTITION BY时，PARTITION BY使用的字段将在值中丢失

我有一个主题test_partition_key_stream，它的模式如下：value:key:null{ "id": 1, "age": 18, "name": "lisa" }然后我这样做了：CREATE STREAM TEST_STREAM_JSON (id INT ,age INT ,name VARCHAR) WITH (KAFKA_TOPIC = 'test_partition_key_stream', VALUE_FORMAT = 'JSON');

CREATE STREAM TEST_STREAM_AVRO WITH (PARTITIONS=3, VALUE_FORMAT='AVRO') AS SELECT * FROM TEST_STREAM_JSON PARTITION BY ID;

但是当我使用PARTITION BY时，“ID”字段将在主题值端丢失。

生成的新主题为：{ "fields": [ { "default": null, "name": "AGE", "type": [ "null", "int" ] }, { "default": null, "name": "NAME", "type": [ "null", "string" ] } ], "name": "KsqlDataSourceSchema", "namespace": "io.confluent.ksql.avro_schemas", "type": "record" }

我想让新主题按ID划分，但我不想在vaule中丢失它。