0
点赞
收藏
分享

微信扫一扫

快速入门Kafka系列(5)——Kafka的命令行操作


        作为快速入门Kafka系列的第五篇博客,本篇为大家带来的是​Kafka的命令行操作​~

        ​码字不易,先赞后看!

快速入门Kafka系列(5)——Kafka的命令行操作_Kafka


文章目录

  • ​​Kafka集群操作​​
  • ​​1. 查看当前服务器中所有Topic​​
  • ​​2. 创建topic​​
  • ​​3. 删除topic​​
  • ​​4. 生产者生产数据​​
  • ​​5. 消费者消费数据​​
  • ​​6. 查看某个 Topic 的详情​​
  • ​​7. 增加topic分区数​​
  • ​​8. 增加配置​​
  • ​​9. 删除配置​​

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操作​​,敬请期待٩(๑❛ᴗ❛๑)۶

快速入门Kafka系列(5)——Kafka的命令行操作_kafka_02



举报

相关推荐

0 条评论