使用schema-registry创建了流,而不指定归档名称,请参阅下面
CREATE STREAM sample_avro WITH (KAFKA_TOPIC='test',VALUE_FORMAT='AVRO');
主题名称 test
在描述主题时包含一些字段和值 主题中的所有字段都显示在下面给出的大写示例中
ksql> describe sample_avro;
Name : SAMPLE_AVRO
Field | Type
---------------------------------------
ROWTIME | BIGINT (system)
ROWKEY | VARCHAR(STRING) (system)
ID | INTEGER
FIRSTNAME | VARCHAR(STRING)
LASTNAME | VARCHAR(STRING)
EMAIL | VARCHAR(STRING)
REG_DATE | BIGINT
在此链接中,KSQL-CASES 归档案例敏感度仅通过在创建流时指定归档名称来保持
。假设主题包含 1000 条记录,用户无法通过指定所有字段名称来创建流。
所以请帮我解决这个问题
这就是 KSQL 目前的工作方式。如果保留 soure Avro 架构:https://github.com/confluentinc/ksql/issues/2415 的大小写对您有用,您可以对此问题发表评论。