Kafka 命令行操作

创建 topic

[root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --create --replication-factor 3 --partitions 1 --topic first

选项说明：

• topic 定义 topic 名
• replication-factor 定义副本数
• partitions 定义分区数 

查看当前服务器中的所有 topic

[root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --list

删除 topic

需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除。 

[root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --delete --topic first

查看某个 Topic 的详情

[root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --describe --topic first

Topic:first    PartitionCount:1    ReplicationFactor:3    Configs:
    Topic: first    Partition: 0    Leader: 0    Replicas: 0,2,1    Isr: 0

发送消息和消费消息的命令一般由API操作，这里不作介绍