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就不报错了。

 

 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM