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
可以修改端口号
2.server.properties
host.name=localhost
zookeeper.connetct=localhost:2181
3.producer.properties
metadata.borker.list=localhost:9092
4.consumer.properties
zookeeper.connect=127.0.0.1:2181
5.centos linux 需要在host文件下做一个映射(必须做主机名和ip的映射,在linux输入hostname查看主机名)
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
二者通话的结果图:
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节点