[Kafka] - Kafka基本操作命令
2017-02-21 11:58
344 查看
Kafka支持的基本命令位于${KAFKA_HOME}/bin文件夹中,主要是kafka-topics.sh命令;Kafka命令参考页面: kafka-0.8.x-帮助文档
[b] -1. 查看帮助信息[/b]
bin/kafka-topics.sh --help
[b]-2. 创建Topic[/b]
bin/kafka-topics.sh --create --topic test0 --zookeeper 192.168.187.146:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1
--create: 指定创建topic动作
--topic:指定新建topic的名称
--zookeeper: 指定kafka连接zk的连接url,该值和server.properties文件中的配置项{zookeeper.connect}一样
--config:指定当前topic上有效的参数值,参数列表参考文档为: Topic-level configuration
--partitions:指定当前创建的kafka分区数量,默认为1个
--replication-factor:指定每个分区的复制因子个数,默认1个
[b]-3. 查看当前Kafka集群中Topic的情况[/b]
bin/kafka-topics.sh --list --zookeeper 192.168.187.146:2181
[b]-4. 查看对应topic的描述信息[/b]
bin/kafka-topics.sh --describe --zookeeper 192.168.187.146:2181 --topic test0
--describe: 指定是展示详细信息命令
--zookeeper: 指定kafka连接zk的连接url,该值和server.properties文件中的配置项{zookeeper.connect}一样
--topic:指定需要展示数据的topic名称
[b]-5. Topic信息修改[/b]
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --config max.message.bytes=128000
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --delete-config max.message.bytes
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --partitions 10
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --partitions 3 ## Kafka分区数量只允许增加,不允许减少
[b]-6. Topic删除[/b]
默认情况下Kafka的Topic是没法直接删除的,需要进行相关参数配置
bin/kafka-topics.sh --delete --topic test0 --zookeeper 192.168.187.146:2181
Note: This will have no impact if delete.topic.enable is not set to true.## 默认情况下,删除是标记删除,没有实际删除这个Topic;如果运行删除Topic,两种方式:
方式一:通过delete命令删除后,手动将本地磁盘以及zk上的相关topic的信息删除即可
方式二:配置server.properties文件,给定参数delete.topic.enable=true,重启kafka服务,此时执行delete命令表示允许进行Topic的删除
[b] -1. 查看帮助信息[/b]
bin/kafka-topics.sh --help
[b]-2. 创建Topic[/b]
bin/kafka-topics.sh --create --topic test0 --zookeeper 192.168.187.146:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1
--create: 指定创建topic动作
--topic:指定新建topic的名称
--zookeeper: 指定kafka连接zk的连接url,该值和server.properties文件中的配置项{zookeeper.connect}一样
--config:指定当前topic上有效的参数值,参数列表参考文档为: Topic-level configuration
--partitions:指定当前创建的kafka分区数量,默认为1个
--replication-factor:指定每个分区的复制因子个数,默认1个
[b]-3. 查看当前Kafka集群中Topic的情况[/b]
bin/kafka-topics.sh --list --zookeeper 192.168.187.146:2181
[b]-4. 查看对应topic的描述信息[/b]
bin/kafka-topics.sh --describe --zookeeper 192.168.187.146:2181 --topic test0
--describe: 指定是展示详细信息命令
--zookeeper: 指定kafka连接zk的连接url,该值和server.properties文件中的配置项{zookeeper.connect}一样
--topic:指定需要展示数据的topic名称
[b]-5. Topic信息修改[/b]
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --config max.message.bytes=128000
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --delete-config max.message.bytes
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --partitions 10
bin/kafka-topics.sh --zookeeper 192.168.187.146:2181 --alter --topic test0 --partitions 3 ## Kafka分区数量只允许增加,不允许减少
[b]-6. Topic删除[/b]
默认情况下Kafka的Topic是没法直接删除的,需要进行相关参数配置
bin/kafka-topics.sh --delete --topic test0 --zookeeper 192.168.187.146:2181
Note: This will have no impact if delete.topic.enable is not set to true.## 默认情况下,删除是标记删除,没有实际删除这个Topic;如果运行删除Topic,两种方式:
方式一:通过delete命令删除后,手动将本地磁盘以及zk上的相关topic的信息删除即可
方式二:配置server.properties文件,给定参数delete.topic.enable=true,重启kafka服务,此时执行delete命令表示允许进行Topic的删除
相关文章推荐
- kafka入门-基本命令操作
- [Kafka] - Kafka基本操作命令
- kafka基本操作命令总结以及Kafka界面化管理链接
- [Kafka] - Kafka基本操作命令
- #####好####Kafka基本操作命令
- kafka基本操作命令
- Git学习笔记(5)----基本操作及命令(远程仓库篇)
- MySQL中Binary Log二进制日志文件的基本操作命令小结
- Java的IO操作(二) - 带缓冲区的流对象、写入基本数据类型、实现命令行中的copy命令
- oracle数据库的基本命令管理与操作
- MySQL基本命令(1)-数据库本身的操作
- Aruba 无线交换机基本操作命令
- GitHub的操作过程及基本命令演示(二)
- docker 入门学习篇【基本命令与操作】
- HADOOP基本操作命令
- Python机器学习:numpy的应用之基本操作命令
- Hadoop基本操作命令
- Git入门——'查询命令'总结与文件的基本操作
- Linux中文件文档的基本操作命令
- linux vim基本操作命令