Topic 相关操作（创建，查看，修改，删除）

创建 topic

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic heilu --partitions 2 --replication-factor 1     // 创建 topic 命令
Created topic heilu.

查看 topic

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh  --zookeeper localhost:2181 --describe --topic heilu  // 查看topic详细信息
Topic:heilu PartitionCount:2    ReplicationFactor:1 Configs:Topic: heilu    Partition: 0    Leader: 0   Replicas: 0 Isr: 0Topic: heilu  Partition: 1    Leader: 0   Replicas: 0 Isr: 0

修改 topic

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh --alter --zookeeper 192.168.131.130:2181 --topic heilu --config flush.messages=1
WARNING: Altering topic configuration from this script has been deprecated and may be removed in future releases.Going forward, please use kafka-configs.sh for this functionality
Updated config for topic heilu.

删除 topic

若 delete.topic.enable=true，直接彻底删除topic。
若 delete.topic.enable=false，如果当前topic没有使用过即没有传输过信息，可以彻底删除。
如果当前topic有使用过即有传输过信息，并没有真正删除topic，只是标记为删除（marked for deletion），重启kafka server 后删除。

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh --delete --zookeeper 192.168.131.130:2181 --topic heilu  // 删除命令
Topic heilu is marked for deletion.  // 结果是 标记为删除
Note: This will have no impact if delete.topic.enable is not set to true.
[root@localhost kafka_2.12-2.2.1]#

添加 partitions

只能添加，不能减少

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh --alter --zookeeper 192.168.131.130:2181 --topic heilu --partitions 3
WARNING: If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected
Adding partitions succeeded!

查看所有topic

[root@localhost kafka_2.12-2.2.1]# bin/kafka-topics.sh --zookeeper localhost:2181 --list   // 查看存在 topic 命令
heilu

Topic 相关操作（创建，查看，修改，删除）相关推荐

MySQL创建/查看/修改/删除数据库
一.创建: 实例1:最简单的创建 MySQL 数据库的语句 mysql> CREATE DATABASE test_db; Query OK, 1 row affected (0.12 sec) ...
第十二讲 dom对象（DOM对象、document对象的常用方法、节点、查找结点、查看/修改/删除属性节点、创建和增加节点）
一.查看节点 getElementById( ) 元素的ID名称来访问,返回对拥有指定id的第一个对象的引用 getElementsByName( ) 按元素的name名称来访问,返回带有指定名称的 ...
数据库MySQL相关操作||创建数据库、显示所有数据库、切换数据库、显示数据库下的数据库表、删除数据库
数据库MySQL相关操作||创建数据库.显示所有数据库.切换数据库.显示数据库下的数据库表.删除数据库 1,创建数据库 create databases mydb: 记得加:(分号) 2,显示所有数据 ...
50.逻辑卷管理5,文件系统相关操作,创建挂载文件系统,扩容文件
文件系统相关操作创建文件系统格式化逻辑卷textlv创建好之后,就可以在上面创建文件系统,以ext4文件系统为例,应该注意的是逻辑卷的引用需要逻辑卷的设备文件,逻辑卷的设备文件有两种书写方式以 ...
Elasticsearch中别名alias相关操作(创建、更新、删除)
1.索引别名概述在Elasticsearch中,别名(alias)是一种将一个或多个索引(index)映射到一个逻辑名称上的方式.通过使用别名,我们可以为目标索引提供简洁.易于理解的名称,并将多个索 ...
MYSQL操作数据库-------查看、删除数据库
上篇我们学习了如何去创建数据库,本篇我们来学习如何查看和删除数据库 1.查看数据库数据库的查看包含三个方面:查看MYSQL中存在的所有数据库.查看当前MySQL命令行所使用的数据库.查看MySQL中 ...
Centos中用户相关操作(创建用户、设置密码、切换用户、修改用户信息、附加组、删除用户、用户分类)
1.创建新用户在root用户权限下新建用户: useradd -m xxx 选项说明 -m 自动创建用户主目录,主目录的名字就是用户名 -g 指定用户所属的用户组,默认不指定会自动创建一个同名的用 ...
C++对于文件的相关操作创建、读写、删除代码
创建 /*** @brief 创建文件:在密码设备内部创建用于存储用户数据的文件* @param pucFileName 缓冲区指针,用于存放输入的文件名,最大长度128字节* @param uiNa ...
Git 高频命令、版本回退、分支操作、文件修改删除、撤销、标签、远程仓库推送、拉取
1. 高频命令 git add 将工作文件修改提交到本地暂存区. git add . 将所有修改过的工作文件提交暂存区(常用). git commit -m "XXX" 为本次修改 ...

Topic 相关操作（创建，查看，修改，删除）

Topic 相关操作（创建，查看，修改，删除）相关推荐

最新文章

热门文章