Обновить поток ksql новой схемой темы - PullRequest
0 голосов
/ 06 сентября 2018

Я пишу авро сообщения в тему кафки, используя схему реестра.Затем создан поток на основе темы.Крик, созданный с использованием текущей схемы.

Затем я добавляю новое поле в схему.Регистр схемы обновлен, все в порядке, но поток остается с первой структурой.

Можно ли обновить поток новой схемой?

Для меня проблематично удалить и снова создать схему, посколькуУ меня есть много других потоков \ таблиц, которые зависят от этого.KSQL не позволяет отбрасывать поток с зависимостями.

1 Ответ

0 голосов
/ 12 марта 2019

Я думаю, что лучший способ остановить потоки и DROP STREAM MYSTREAM.

https://docs.confluent.io/current/ksql/docs/developer-guide/create-a-stream.html#delete-a-ksql-stream

...