Могу ли я изменить таблицу KSQL с формата AVRO на JSON?

Question

Я пытаюсь получить таблицу формата JSON для моего скрипта python, чтобы получить к нему доступ, и не хочу менять исходный формат темы, поскольку он в настоящее время находится в формате AVRO.

Итак, мой вопрос: возможно ли перейти с формата AVRO на формат JSON? Либо из потока в таблицу, либо из таблицы в таблицу.

Answer 1

Да, вы можете указать альтернативу VALUE_FORMAT и создать производный поток / таблицу:

CREATE STREAM foo_json WITH (VALUE_FORMAT='JSON') AS SELECT * FROM foo_avro;