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(-实际功能尚未添加。不过，这方面还有很多工作正在进行中，请继续关注！