首页 文章

如何从DCOS Kafka删除主题?

提问于
浏览
4

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

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

这说它已经标记了要删除的主题,但除非“delete.topic.enable = true”,否则它将无效 . 尝试使用以下每个代理设置:

dcos kafka broker update 1 --options delete.topic.enable = true`

然后重新启动经纪人

该主题仍然存在,仍然标记为删除 . 如何让经纪人删除该主题?

1 回答

  • 0

    要覆盖此参数,您需要将以下环境变量添加到Kafka服务:

    KAFKA_OVERRIDE_DELETE_TOPICS=true
    

    你可以在DCOS服务定义中通过编辑按钮然后环境变量形式更新 .

    您会注意到它会更改您的配置描述符(json文件):

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

    使用此设置重新启动服务后,您可以使用以下命令删除任何主题:

    dcos kafka topic delete <topicname>
    

相关问题