无法从cmd实用程序中删除Kafka主题并以编程方式删除（Java）

Question

我不能删除Kafka的主题，他们只是标记为删除。有什么问题？我是不是漏掉了什么？欢迎提出任何建议。

我尝试用两种方法删除Kafka主题：

kafka-topics.bat --delete --zookeeper localhost:2181 --topic Cat

public void deleteSomeTopic() throws Exception {

  consumer = new SimpleConsumer(host, port, soTimeout,  bufferSize,"deleteClient");

  List<String> listTopics = new ArrayList<>();
  TopicMetadataRequest request = new TopicMetadataRequest(listTopics);

  //consumer will send request and get corresponding response
  TopicMetadataResponse response = consumer.send(request);

  //getting topicMetadata list
  List<TopicMetadata> topicMetadataList = response.topicsMetadata();

  for (TopicMetadata topicMetadata: topicMetadataList) {
     System.out.println("Do you want to delete this Topic: "+ topicMetadata.topic());
     String ch = scanner.next();
     if(ch.equalsIgnoreCase("y"))
        AdminUtils.deleteTopic(zkClient, topicMetadata.topic());
     Thread.sleep(2000);
  }
}

kafka-topics.bat --list -zookeeper localhost:2181

Ape - marked for deletion   
Cat - marked for deletion     
Dog - marked for deletion   
Elephant                    
apple                       
carrot                      
ginger - marked for deletion
guava                       
mango                      

controlled.shutdown.enable=true
delete.topic.enable=true

我使用的是kafka2.10-0.8.2.2，我的pom.xml文件只有两个依赖项。

<dependencies>
    <dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-streaming_2.10</artifactId>
        <version>1.5.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-streaming-kafka_2.10</artifactId>
        <version>1.5.1</version>
    </dependency>
</dependencies>

我还检查了tmp/kafka-logs目录，主题目录还在。我需要做什么变通办法吗？

Answer 1

根据列表命令的输出，您似乎正确地告诉Kafka您想删除一个主题。出于某种原因，Kafka没有删除它。在版本0.8.2之前的Kafka中有一个错误，它阻止了主题删除。查看该bug请求的注释，您正在运行的0.8.2.2似乎仍然存在一些问题。也许这个bug还没有完全修复？

基于您的Kafka.bat文件，是否在windows环境中运行Kafka？您是否对默认server.properties文件进行了许多更改？或者您基本上使用的是Kafka附带的默认文件？这可能是与Windows相关的问题，我只在Linux上使用过它。使用几乎所有的默认值，只有设置delete.topic.enable=true deletion在Linux上一直对我有效。随机猜测，但也许这不是在Windows环境或。bat文件中修复的？

不过，基于这个堆栈溢出答案和对原始bug报告的注释，似乎存在一个解决方案。我从来没有用过，也许可以试试看？