Как динамически обновить определение потока KSQL на основе схемы реестра

Question

Я создал поток KSQL на основе схемы-реестра, выполнив эту запись .Соединитель JDBC Kafka обновляет последнюю схему в реестре схем.Новый поток создается с самой последней схемой, но существующий поток имеет более старую схему.

Я не знаю, когда схема источника данных изменяется.В этом случае я ожидаю, что KSQL динамически обновит свое определение с помощью новейшей схемы, доступной в schema-registry.

Есть идеи?Как этого добиться?

Answer 1

В данный момент вам нужно вручную отбросить и заново создать поток, чтобы подобрать новую схему.

Я вошел в систему # 2215 , если вы хотите поднять / обсудить желаемое поведение там.