Kafka的shell命令使用
一、创建topic
创建一个topic（主题）。Kafka中所有的消息都是保存在主题中，要生产消息到Kafka，首先必须要有一个确定的主题。
代码语言：javascript复制# 创建名为test的主题
bin/kafka-topics.sh --create --bootstrap-server node1:9092 --topic test
# 查看目前Kafka中的主题
bin/kafka-topics.sh --list --bootstrap-server node1:9092二、生产消息到kafka
使用Kafka内置的测试程序，生产一些消息到Kafka的test主题中。
代码语言：javascript复制bin/kafka-console-producer.sh --broker-list node1:9092 --topic test三、从kafka中消费消息
使用下面的命令来消费 test 主题中的消息。
代码语言：javascript复制bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test四、查看主题的命令
查看 kafka 当中存在的主题
代码语言：javascript复制bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181五、运行describe的命令
运行 describe 查看 topic 的相关详细信息
代码语言：javascript复制bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test
六、 增加topic分区数
任意 kafka 服务器执行以下命令可以增加 topic 分区数
代码语言：javascript复制bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName --partitions 8七、删除topic
目前删除 topic 在默认情况下知识打上一个删除的标记，在重新启动 kafka 后才删除。如果需要立即删除，则需要 在server.properties 中配置：
代码语言：javascript复制delete.topic.enable=true然后执行以下命令进行删除 topic
代码语言：javascript复制bin/kafka-topics.sh --zookeeper zkhost:port --delete --topic topicName八、使用kafka Tools操作Kafka
1、安装Kafka Tools后启动Kafka, 并连接kafka集群
2、安装Kafka Tools后启动Kafka, 并连接kafka集群
3、使用kafka Tools操作Kafka
创建 topic
查看分区中的数据
