我可以将 KSQL table 从 AVRO 格式更改为 JSON 格式吗?
Can I change KSQL table from AVRO to JSON format?
我正在尝试为我的 python 脚本提供 JSON 格式 table 来访问它,并且不想更改当前在 AVRO 中的原始主题格式格式。
所以我的问题是,可以将 AVRO 格式更改为 JSON 格式吗?从流到 table,或从 table 到 table。
是的,您可以指定备选方案 VALUE_FORMAT
并创建派生的 stream/table:
CREATE STREAM foo_json WITH (VALUE_FORMAT='JSON') AS SELECT * FROM foo_avro;
我正在尝试为我的 python 脚本提供 JSON 格式 table 来访问它,并且不想更改当前在 AVRO 中的原始主题格式格式。
所以我的问题是,可以将 AVRO 格式更改为 JSON 格式吗?从流到 table,或从 table 到 table。
是的,您可以指定备选方案 VALUE_FORMAT
并创建派生的 stream/table:
CREATE STREAM foo_json WITH (VALUE_FORMAT='JSON') AS SELECT * FROM foo_avro;