Обновить поток ksql новой схемой темы

Question

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

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

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

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

Answer 1

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

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