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

#apache-kafka #ksqldb

#apache-kafka #ksqldb

Вопрос:

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

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

Ответ №1:

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

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