作为快速入门Kafka系列的第五篇博客，本篇为大家带来的是Kafka的命令行操作~
码字不易,先赞后看!
Kafka集群操作
首先进入到kafka的安装目录下
cd /export/servers/kafka_2.11-1.0.0
1. 查看当前服务器中所有Topic
bin/kafka-topics.sh --list --zookeeper node01:2181,node02:2181,node03:2181
2. 创建topic
bin/kafka-topics.sh --create --zookeeper node01:2181 --replication-factor 2 --partitions 3 --topic test
选项申明:
- - -topic 定义topic名
- - -replication-factor 定义副本数
- - -partitions 定义分区数
3. 删除topic
目前删除topic在默认情况下知识打上一个删除的标记，在重新启动kafka后才删除。如果需要立即删除，则需要在server.properties中配置：
delete.topic.enable=true
然后执行以下命令进行删除topic
kafka-topics.sh --zookeeper node01:2181 --delete --topic topicName
4. 生产者生产数据
模拟生产者来生产数据
node01服务器执行以下命令来模拟生产者进行生产数据
bin/kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic test
5. 消费者消费数据
node02服务器执行以下命令来模拟消费者进行消费数据
bin/kafka-console-consumer.sh --from-beginning --topic test --zookeeper node01:2181,node02:2181,node03:2181
- - -from-beginning:会把主题中以往所有的数据都读取出来。
6. 查看某个 Topic 的详情
bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test
7. 增加topic分区数
任意kafka服务器执行以下命令可以增加topic分区数
bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName --partitions 8
8. 增加配置
动态修改kakfa的配置
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --config flush.messages=1
9. 删除配置
动态删除kafka集群配置
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --delete-config flush.messages
好了，本期的内容分享就到这里了，受益或对大数据技术感兴趣的朋友记得点赞关注一下博主，下一篇博客将为大家带来kafka的JavaAPI操作，敬请期待٩(๑❛ᴗ❛๑)۶
