ksqldb 是否支持流的创建或替换?

does ksqldb support the create or replace for a stream?

我是通过阅读一些 Whosebug post 了解如何在流及时更改时重新定义流的。 我一直在寻找并最终出现在这个 PR 中:https://github.com/confluentinc/ksql/pull/5611

理论上应该可以,但是如果我只看文档我找不到它 https://docs.ksqldb.io/en/latest/developer-guide/create-a-stream/

现在我在我的 ksqldb 中尝试它,但出现错误:

ksql> CREATE OR REPLACE STREAM obj_pos_proto (id INT, obj_type_id INT) WITH (KAFKA_TOPIC='obj_pos', VALUE_FORMAT='PROTOBUF');
line 1:8: no viable alternative at input 'CREATE OR'

是让这个工作删除然后重新创建的唯一方法吗?

目前不支持。您看到的 github 合并是设计文档 (KLIP) - 实际功能尚未添加。不过,这方面还有很多工作正在进行,敬请期待!