kafka的topic默认是不允许被删除的,删除后在topic后会出现”marked for deletion”字样,实际并未删除,现在创建同样的topic会提示topic已经存在。

解决办法:

server.properties配置文件中添加:delete.topic.enable=true

之后重启kafka,会发现之前被标记删除的topic已经不存在了。

 

kafka操作基本命令:

创建topic(replication-factor为集群broker数量):

bin/kafka-topics.sh --create --zookeeper zkserver:zkport --replication-factor 1 --partitions 1 --topic topic-name

删除topic:

bin/kafka-topics.sh --delete --zookeeper zkserver:zkport --topic topic-name

查看topic消费消息:

 

kafka-console-consumer --zookeeper zkserver:2181 --topic ${topic-name} --from-beginning

 

查看topic列表:

bin/kafka-topics.sh --list --zookeeper zkserver:zkport --topic    

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-11-05
  • 2021-08-24
  • 2021-10-19
  • 2021-08-07
  • 2021-06-29
猜你喜欢
  • 2021-08-06
  • 2022-02-08
  • 2021-07-26
  • 2021-05-05
  • 2021-05-12
相关资源
相似解决方案