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

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

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


apache-kafka ksqldb
person kurapika    schedule 03.04.2019    source источник

Ответы (1)


arrow_upward
2
arrow_downward

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

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

person Robin Moffatt    schedule 03.04.2019