kafka学习二:在linux环境下kafka搭建环境(单机版)

时间:2021-07-31 12:11:14

1.下载kafka软件包:这里使用2.10版本的kafka

2. 解压缩kafka软件包:这里将软件包放在 softpackage0324文件下

 cd softpackage0324

tar -zxvf kafka_2.10-0.8.2.1.tgz

3.进入 kafka_2.10-0.8.2.1

 cd   kafka_2.10-0.8.2.1

4.修改配置文件:进入config文件夹下:

  1.zookeeper.properties

 可以修改端口号
kafka学习二:在linux环境下kafka搭建环境(单机版)
 
 
 
 2.server.properties
host.name=localhost
zookeeper.connetct=localhost:2181
kafka学习二:在linux环境下kafka搭建环境(单机版)
 
 
 3.producer.properties
metadata.borker.list=localhost:9092
kafka学习二:在linux环境下kafka搭建环境(单机版)
 4.consumer.properties
zookeeper.connect=127.0.0.1:2181
kafka学习二:在linux环境下kafka搭建环境(单机版)
5.centos linux 需要在host文件下做一个映射(必须做主机名和ip的映射,在linux输入hostname查看主机名)
kafka学习二:在linux环境下kafka搭建环境(单机版)
6.进入kafka_2.10-0.8.2.1的根目录下(每执行一条命令,执行ctr+c)
   1.启动zookeepr
 bin/zookeeper-server-start.sh config/zookeeper.properties &
   2.启动kafka
   bin/kafka-server-start.sh config/server.properties &
   3.创建topic 
 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
   4.查询现有的topics
   bin/kafka-topics.sh --list --zookeeper localhost:2181 
  5.创建producer,发送消息
 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
  6.在另外开启一个窗口:消费者消费信息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
二者通话的结果图:
kafka学习二:在linux环境下kafka搭建环境(单机版)
kafka学习二:在linux环境下kafka搭建环境(单机版)
7.删除topic

1) kafka-topics.sh --delete --zookeeper host:port --topic topicname

2) 删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录删除zookeeper "/brokers/topics/"目录下相关topic节点