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

问题描述

我通过阅读一些stackoverflow帖子了解了有关如何在流变化时重新定义流的信息。 我一直在寻找并最终到达此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）-实际功能尚未添加。不过，该领域正在进行很多工作，敬请期待！