1、如果配置了delete.topic.enable=true 适合以下操作

  • 通过命令删除:./kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic apply_test
  • 通过zookeeper-client 删除掉broker下的topic, rmr /brokers/topics/apply_test
  • 删除kafka节点的 kafka/logs/apply_test-0,
  • 然后重启kafka集群
  • 重新创建即可: /data1/xinsrv/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic apply_test

相关文章:

  • 2022-12-23
  • 2021-12-11
  • 2021-10-15
  • 2021-09-25
  • 2022-12-23
  • 2022-12-23
  • 2021-10-14
  • 2021-09-13
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2021-06-11
  • 2022-12-23
  • 2021-07-31
  • 2021-08-11
  • 2021-07-04
相关资源
相似解决方案