首页 > 其他 > 详细

二、kafka的环境部署+命令行

时间:2021-08-30 05:21:10      阅读:13      评论:0      收藏:0      [点我收藏+]

1、kafka的安装部署

因为我这边只有一个阿里云服务器,且配置贼低,所以我就不部署集群,直接部署一个单机版的测试玩玩

1)新建soft文件夹,并将kafka的jar上传到该文件夹下

技术分享图片


2)解压压缩包,并将解压后的文件名改为 kafka

tar -zxvf kafka_2.11-0.11.0.0.tgz mv kafka_2.11-0.11.0.0 kafka

技术分享图片


3)在kafka文件下创建log文件夹

技术分享图片


4)备份并修改kafka的配置文件server.properties

cp server.properties server.properties.back vim server.properties

修改内容参考如下:

技术分享图片


本地做的修改主要是:

broker.id=0 delete.topic.enable=true log.dirs=/soft/kafka/logs zookeeper.connect=121.40.182.123:2181


5)启动 kafka

bin/kafka-server-start.sh -daemon config/server.properties


6)查看kafka是否正常启动

jps

技术分享图片


2、kafka的命令行操作

1)查看当前kafka服务器中的所有Topic

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

技术分享图片


2)创建topic

选项说明:

--topic 定义 topic 名

--replication-factor 定义副本数 (副本数不能超过 broker的数量)

--partitions 定义分区数


bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic first --replication-factor 1 --partitions 1

技术分享图片

查看上述配置的logs文件夹,发现多了个first-0文件夹(主题+分区号)

===》 kafka的消息是存储到磁盘的

技术分享图片


3)删除topic

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic first


4)查看topic的详情

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --descripe --topic first

技术分享图片


5)修改分区数

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic first --partitions 6


6)发送消息

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first


7)消费消息

bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic first

技术分享图片

上面这种消费方式,当生产者发送消息时,消费者不在线,然后消费者启动后,消费不到生产者刚刚发送的消息

--from-beginning:会将主题中以往的所有数据都消费到

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic first

技术分享图片

二、kafka的环境部署+命令行

原文:https://www.cnblogs.com/houchen/p/15201987.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!