使用KSQL (Confluent: Version: 5.0.1),当链接的主题存在并且注册时(Registered=true),我能够正常地删除表/流(使用DROP [TABLE|STREAM]
) <NAME>
。
然而,如果主题首先被删除(Registered=false),那么相关的流或表就不能被删除,因为KSQL指出“没有注册名为Foo的主题”。
问题是流/表仍然显示在列表中,并且不能使用相同的名称添加新的流/表。
有没有办法在删除该主题后将其删除?
发布于 2019-04-08 07:19:24
我想我找到了答案,或者至少找到了正确的方向。
您需要在流中重新注册主题。在进行了一些修改之后,我设法将我的主题重新附加到流,即删除流。
REGISTER TOPIC <ksql_topic_name> WITH (KAFKA_TOPIC='<kafka_topic_name>', VALUE_FORMAT='<format>');
然后,
DROP STREAM <stream_name>;
我不知道这是否在所有情况下都有效,但它让我回到了我想要的地方。如果其他人能对此进行迭代,并找到一个更健壮的解决方案,我很乐意听到。
发布于 2020-05-10 23:42:22
您必须首先终止所有正在运行的查询。
SHOW QUERIES; --> that will show you the active queries (COPY QUERY ID)
然后:
TERMINATE [QUERY ID];
然后:丢弃表或流;
https://stackoverflow.com/questions/53729164
复制相似问题