kafka----------------topic的创建，查询，删除详解

**

在kafka中要创建topic，首先的保证zookeeper是正常启动的，如果你有集群，要启动全部集群

**
zookeeper的启动命令：

/export/server/zookeeper/bin/zkServer.sh start

启动完毕后在用jps查看下，确保启动正确
（也要启动其他集群的zookeeper）

创建topic

创建名为test的主题，有三个分区，两个副本

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --create --zookeeper node01:2181 --replication-factor 2 --partitions 3 --topic test

查看topic

查看kafka中存在的主题

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --list --zookeeper node01:2181,node02:2181,node03:2181

生产者生产数据

模拟生产者来生产数据

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-console-producer.sh --broker-list
node01:9092,node02:9092,node03:9092 --topic test

消费者消费数据

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-console-consumer.sh --from-beginning --topic test
--zookeeper node01:2181,node02:2181,node03:2181

运行describe的命令

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

第一行给出了所有分区的摘要，主题名字，分区个数，副本个数
“leader”是负责给定分区的所有读取和写入的节点。每个节点将成为随机选择的分区部分的领导
者。（因为在kafka中 如果有多个副本的话，就会存在leader和follower的关系，表示当前这个副
本为leader所在的broker是哪一个）
“replicas”是复制此分区日志的节点列表，无论它们是否为领导者，或者即使它们当前处于活动状
态。（所有副本列表 0 ，1,2）
“isr”是“同步”复制品的集合。这是副本列表的子集，该列表当前处于活跃状态并且已经被领导者捕
获。（可用的列表 数）

增加topic分区数

任意kafka服务器执行以下命令可以增加topic分区数

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName -- partitions 8

增加配置

动态修改kafka得配置

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --config flush.messages=1

删除配置

动态删除kafka集群配置

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --delete- config flush.messages

删除topic

目前删除topic在默认情况下知识打上一个删除的标记，在重新启动kafka后才删除。
如果需要立即 删除，则需要在
server.properties中配置：
delete.topic.enable=true
然后执行以下命令进行删除topic

kafka-topics.sh --zookeeper zkhost:port --delete --topic topicName