ksqldb是否支持创建或替换流？

Question

我是通过阅读一些stackoverflow帖子来实现这一点的，这些文章讲述了如何在流发生变化时重新定义它。我一直在寻找，最后得到了这个公关：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'

让它工作的唯一方法是删除然后重新创建吗？

Answer 1

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