kafka主题

悠悠 2022-05-24 01:06 274阅读 0赞

一、创建topic

  1. # zookeeper指定其中一个节点即可，集群之间会自动同步
  2. ./bin/kafka-topics.sh --create --zookeeper 192.168.238.132:2181 --replication-factor 2 --partitions 3 --topic test_topic

二、查看topic

  1. #查看全部topic
  2. ./bin/kafka-topics.sh --list --zookeeper 192.168.238.132:2181
  4. # 查看某个topic的详细信息
  5. ./bin/kafka-topics.sh --describe --zookeeper 192.168.238.131:2181 --topic test_topic

三、删除topic

  1. ./bin/kafka-topics.sh  --delete --zookeeper 192.168.238.131:2181  --topic test_topic

如果kafaka启动时加载的配置文件中 server.properties 没有配置delete.topic.enable=true，那么此时的删除并不是真正的删除，而是把topic标记为：marked for deletion
deleteTopic
被标记为删除后的topic：
deletedTopic

此时你若想真正删除它，可以如下操作：

  1. ./bin/zkCli.sh -server 192.168.238.132:2181 # 客户端连接zk服务器
  2. ls /brokers/topics # zk中查看topic所在的目录
  3. rmr /brokers/topics/test_topicaaa # 删除要彻底删除的topic
  4. # 删除kafka存储目录（server.properties文件log.dirs配置，默认为"/tmp/kafka-logs"）相关topic目录

也可以去掉topic的：marked for deletion标记：

  1. ./bin/zkCli.sh -server 192.168.238.132:2181 # 客户端连接zk服务器
  2. ls /admin/delete_topics # 查看被标记为marked for deletion的topic
  3. rmr /admin/delete_topics/test_topicaaa

在./conf/server.properties 中添加：delete.topic.enable=true

四、修改topic

topic分区只能添加，不能减少

  1. # 添加到8个分区
  2. ./bin/kafka-topics.sh --alter --zookeeper 192.168.238.145:2181 --partitions 8 --topic test_topic

发表评论

表情：
评论列表 （有 0 条评论，274人围观）

还没有评论，来说两句吧...

相关阅读

    相关 kafka主题

    一、创建topic zookeeper指定其中一个节点即可，集群之间会自动同步 ./bin/kafka-topics.sh --create --zoo

    悠悠悠悠/ 0 赞/ 275 阅读