如何从 DCOS Kafka 中删除主题？

【问题标题】：How can I delete a topic from DCOS Kafka?如何从 DCOS Kafka 中删除主题？
【发布时间】：2016-04-17 07:40:51
【问题描述】：

我们通过 DCOS 运行 Kafka。我们有一个主题似乎有一些不良数据。我想删除那个话题。

尝试运行： kafka-topics.sh --zookeeper --delete --topic

这表示它已将主题标记为删除，但除非“delete.topic.enable=true”，否则它将不起作用。尝试使用以下方式为每个代理设置：

dcos kafka 代理更新 1 --options delete.topic.enable=true`

然后重新启动代理

主题仍然存在并且仍标记为删除。如何让经纪人删除该主题？

【问题讨论】：

【解决方案1】：

为了覆盖此参数，您需要将以下环境变量添加到 Kafka 服务：

KAFKA_OVERRIDE_DELETE_TOPICS=true

您可以在 DCOS 服务定义中非常简单地更新它，通过编辑按钮然后环境变量表单。

您会注意到它会更改您的配置描述符（json 文件）：

...
"env": {
   ...
   "KAFKA_OVERRIDE_DELETE_TOPICS": "true",
   ...
}
...

使用此设置重新启动服务后，您可以使用以下方法删除任何主题：

dcos kafka topic delete <topicname>

【讨论】：