#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;