kafka常见问题
Easul Lv6

kafka常见问题

  • 删除topic时提示This will have no impact if delete.topic.enable is not set to true
    折叠代码块BASH 复制代码
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    # 每个结点配置
    vi $KAFKA_HOME/config/server.properties

    # 将该项设置为true
    delete.topic.enable=true

    # 然后就可以删除topic了
    kafka-topics.sh --zookeeper master:2181,slave1:2181,slave2:2181 --delete --topic test

    # 但是因为之前已经将某些topic标记为删除,所以这些文件夹需要手动删除。
    # 每个结点都需要操作
    ls -al kafka-logs
    # 删除其中topic相关的目录
    rm -rf kafka-logs/test*
    # 进入到zookeeper的命令行
    zkCli.sh
    # 找到相关topic
    [zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
    [zk: localhost:2181(CONNECTED) 0] ls /config/topics
    [zk: localhost:2181(CONNECTED) 0] ls /admin/delete_topics
    # 删除要删除的topic,这样marked for deletion就消失了,而且再创建新的同名topic也没有问题
    [zk: localhost:2181(CONNECTED) 0] rmr /brokers/topics/test
    [zk: localhost:2181(CONNECTED) 0] rmr /config/topics/test
    [zk: localhost:2181(CONNECTED) 0] rmr /admin/delete_topics/test
    delete.topic.enable的设置
    彻底删除kafka中的topic
    Kafka marked for deletion强制删除
 评论
来发评论吧~
Powered By Valine
v1.5.2