kafka~~linux下的操作

Posted 2021-03-14 扎克伯格～

安装与配置

1.使用Xshell上传kafka压缩包到linux

2.使用 tar -vxzf 进行解压

3.进入 kafka config 下的 server.properties 进行配置

borker.id=1 kafka服务器节点设置id为1

释放注释 listeners 监听

listeners=PLAINTEXT://192.168.150.129:9092 

设置linux ip地址

为了能够创建消费者 和生产者

配置kafka日志地址

log.dirs=/usr/yc/imooc-coupon/soft/kafka_log

 

启动

kafka

进入kafka目录下 

先启动zookeeper 以daemon后台模式启动

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

再启动kafka

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

通过jps命令查询是否启动

39348 Kafka
39317 QuorumPeerMain 这是zookeeper

 

创建

topic(主题) 用于存放消息的

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

查询topic

bin/kafka-topics.sh --list --zookeeper localhost

 

消费者 

bin/kafka-console-consumer.sh --bootstrap-server 192.168.150.129:9092 --topic second-kafka-topic --from-beginning

生产者

bin/kafka-console-producer.sh --broker-list 192.168.150.129:9092 --topic second-kafka-topic