zoukankan      html  css  js  c++  java
  • 【Kafka】Kafka topic主题删除不了

    前言

    利用kafka命令删除topic不成功。

    kafka-topics.sh --zookeeper hadoop111:2181 --delete --topic test
    

    原因&解决方式

    1. 配置文件未将delete.topic.enable=true,导致删除命令未及时生效;

    解决方式:

    第一种:

    找到conf目录下server.properties配置文件,修改delete.topic.enable=true,代表删除立即生效;

    [ssrs@hadoop111 config]$ pwd
    /opt/module/kafka_2.11/config
    [ssrs@hadoop111 config]$ vi server.properties
    
    delete.topic.enable=true
    

    修改配置后,需要重启kafka服务;

    第二种:

    不修改delete.topic.enable=true配置文件的情况下,删除命令执行后,重启kafka服务,也可以使主题删除成功;

    2. 配置文件已经设置delete.topic.enable=true,删除命令执行后,还能看到topic名称;

    原因:

    生产者和消费者并未停止执行,导致虽然删除了topic,但是生产者或者消费者运行时,立刻重新创建了topic,视觉显示删除未成功,此时可以通过消费topic内的数据进行查看,如果之前是带有数据的topic,在执行删除命令后,发现topic内的数据已经消失了。

    解决方式:

    先停止生产者和消费者的运行,再执行kafka删除命令;

  • 相关阅读:
    HDU 6125
    HDU 6129
    Super Jumping! Jumping! Jumping!
    HDU 1040 As Easy As A+B(排序)
    VS2015转VS2008
    HDU 1329 Hanoi Tower Troubles Again!(乱搞)
    HDU 1062 Text Reverse(字符串)
    HDU 1013 Digital Roots(字符串)
    HDU 1003 Max Sum(动态规划)
    HDU 1203 I NEED A OFFER!(01背包)
  • 原文地址:https://www.cnblogs.com/ShadowFiend/p/12895325.html
Copyright © 2011-2022 走看看