zoukankan      html  css  js  c++  java
  • kafka删除topic后再创建同名的topic报错(ERROR org.apache.kafka.common.errors.TopicExistsException)

    [hadoop@datanode3 logs]$ kafka-topics.sh --delete --zookeeper datanode1:2181 --topic first
    Topic first is marked for deletion.
    Note: This will have no impact if delete.topic.enable is not set to true.

    [hadoop@datanode3 logs]$ kafka-topics.sh  --create --zookeeper datanode1:2181 --partitions 2 --replication-factor 3 --topic first

    Error while executing topic command : Topic 'first' already exists.

    [2019-07-13 07:11:05,073] ERROR org.apache.kafka.common.errors.TopicExistsException: Topic 'first' already exists.

     (kafka.admin.TopicCommand$)

    报错原因是我当时kafka-console-producer.sh和kafka-console-consumer.sh都还在运行,删除只删除了部分patition

    后来关掉kafka-console-producer.sh和kafka-console-consumer.sh进程后,再删除,再创建同名的topic就不报错了。

     

  • 相关阅读:
    三、checkedListBoxControl
    三、安装MyCat-Web
    三、zookeeper安装
    二、.Net 连接mycat
    一、MyCat的搭建
    二、优惠卷
    二、Docker部署应用
    【2019-05-08】感知当下
    【一句日历】2019年7月
    【读书】2019
  • 原文地址:https://www.cnblogs.com/mkl34367803/p/11182365.html
Copyright © 2011-2022 走看看