小编Kub*_*bus的帖子

如何通过 Rest api 或至少作为 ksqldb-cli 中的语句来标记 ksql 表中的行以进行删除？

CREATE TABLE movies (
      title VARCHAR PRIMARY KEY,
      id INT,
      release_year INT
    ) WITH (
      KAFKA_TOPIC='movies',
      PARTITIONS=1,
      VALUE_FORMAT = 'JSON'
    );

INSERT INTO MOVIES (ID, TITLE, RELEASE_YEAR) VALUES (48, 'Aliens', 1986);

由于明显的原因，这不起作用，但是 ksqldb 中不存在 DELETE 语句：

INSERT INTO MOVIES (ID, TITLE, RELEASE_YEAR) VALUES (48, null, null);

有没有办法创建推荐的逻辑删除空值，或者我是否需要将其直接写入基础主题？