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

【问题标题】：does ksqldb support the create or replace for a stream?ksqldb 是否支持流的创建或替换？
【发布时间】：2020-09-29 01:27:42
【问题描述】：

我通过阅读一些有关如何在流发生变化时重新定义流的 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'

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

【问题讨论】：

REPLACE 流被添加到 0.12.0 docs.ksqldb.io/en/0.12.0-ksqldb/developer-guide/…的文档中

标签： apache-kafka ksqldb

【解决方案1】：

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

【讨论】：

谢谢你，现在我用 drop / create 做得很好