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

Question

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

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

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

Answer 1

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

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