kafka主题

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

# 一、创建topic #

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

# 二、查看topic #

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

# 三、删除topic #

./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][]

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

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

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

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

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

# 四、修改topic #

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

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

[deleteTopic]: /images/20220524/d4e3c3dd86b74f4fa5160423a16b60c7.png
[deletedTopic]: /images/20220524/07f30b4419de4d9594a0643af177c2ba.png

发表评论取消回复

表情：

评论列表（有 0 条评论，208人围观）

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

相关阅读

相关 Kafka：修改Topic主题的分区数

注意：分区数可以增加，但是不能减少。需求：修改主题 test 为 7 个分区。 bin/kafka-topics.sh --bootstrap-server

女爷i/ 2024年03月25日 22:47/ 0 赞/ 43 阅读

相关 Kafka：增加Topic主题副本数量

在生产环境当中，由于某个主题的重要等级需要提升，我们考虑增加副本。副本数的增加需要先制定计划，然后根据计划执行。 1）创建 topic test bin/kaf

朱雀/ 2024年03月25日 21:51/ 0 赞/ 105 阅读

相关 Kafka：自动创建主题

如果 broker 端配置参数 auto.create.topics.enable 设置为 true（默认值是 true），那么当生产者向一个未创建的主题发送消息时，会自动创

柔情只为你懂/ 2024年03月24日 15:14/ 0 赞/ 37 阅读

相关 kafka删除主题数据和删除主题

版权声明：本文为博主原创文章，转载注明出处。 https://blog.csdn.net/forrest\_ou/article/details/78999983 kafka

Love The Way You Lie/ 2023年10月18日 11:02/ 0 赞/ 18 阅读

相关 wurstmeister/kafka设置__consumer_offsets主题副本数

新版本的kafka会把每个主题消费进度保存在kafka所在机器的\_\_consumer\_offsets主题下面，该主题默认副本数为1，当一台机器down掉后，该机器保存的主

秒速五厘米/ 2023年01月09日 15:33/ 0 赞/ 192 阅读

相关 kafka删除主题

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5a2m5Lqu57yW5

忘是亡心i/ 2022年09月11日 06:20/ 0 赞/ 22 阅读

相关 Kafka介绍, kafka主题的副本机制

1、Kafka概览 Apache下的项目Kafka(卡夫卡)是一个分布式流处理平台，它的流行是因为卡夫卡系统的设计和操作简单，能充分利用磁盘的顺序读写特性。kafka每秒钟能

╰+攻爆jí腚メ/ 2022年06月17日 14:24/ 0 赞/ 270 阅读

相关 kafka主题

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

悠悠/ 2022年05月24日 01:06/ 0 赞/ 209 阅读

相关 Kafka删除主题topic

1.关闭所有和topic相关的生产者和消费者 2.在server.properties添加设置 kafka topic可删除 delete.topic.enable=tr

红太狼/ 2022年03月19日 06:23/ 0 赞/ 164 阅读

相关 Flume 监控kafka主题写HDFS小结

Flume 监控kafka主题写HDFS小结需求采集Flume采集kafka主题内容，往Hadoop集群上写HDFS，该机器没有安装Hadoop 这里的Flume版本

心已赠人/ 2022年03月15日 15:56/ 0 赞/ 205 阅读