我们正在通过dcos运行Kafka。我们有一个主题，似乎有一些坏数据。我想删除这个主题。
尝试运行：kafka-topics.sh--zookeeper--delete--topic
这表示它已将主题标记为删除，但除非“delete.topic.enable=true”，否则它将不起作用。尝试使用以下方法为每个代理设置：
dcos kafka broker更新1--选项delete.topic.enable=true`
然后重启了经纪人
主题仍然存在，并且仍标记为删除。如何让代理删除该主题？
我们正在通过dcos运行Kafka。我们有一个主题，似乎有一些坏数据。我想删除这个主题。
尝试运行：kafka-topics.sh--zookeeper--delete--topic
这表示它已将主题标记为删除，但除非“delete.topic.enable=true”，否则它将不起作用。尝试使用以下方法为每个代理设置：
dcos kafka broker更新1--选项delete.topic.enable=true`
然后重启了经纪人
主题仍然存在，并且仍标记为删除。如何让代理删除该主题？
1条答案
按热度按时间slhcrj9b1#
要覆盖此参数，需要将以下环境变量添加到kafka服务：
您可以在dcos服务定义中非常简单地更新它，通过edit按钮，然后通过environment variables表单。
您会注意到它更改了配置描述符（json文件）：
使用此设置重新启动服务后，您可以使用以下方法删除任何主题：