我是通过阅读一些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'

只有这样才能让它工作掉，然后再创建一次吗？