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

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

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

 cdsoftpackage0324

tar-zxvfkafka_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.centoslinux需要在host文件下做一个映射（必须做主机名和ip的映射，在linux输入hostname查看主机名）

6.进入kafka_2.10-0.8.2.1的根目录下（每执行一条命令，执行ctr+c）

1.启动zookeepr

bin/zookeeper-server-start.shconfig/zookeeper.properties&

2.启动kafka

bin/kafka-server-start.shconfig/server.properties&

3.创建topic

bin/kafka-topics.sh--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictest

4.查询现有的topics

bin/kafka-topics.sh--list--zookeeperlocalhost:2181

5.创建producer，发送消息

bin/kafka-console-producer.sh--broker-listlocalhost:9092--topictest

6.在另外开启一个窗口：消费者消费信息

bin/kafka-console-consumer.sh--zookeeperlocalhost:2181--topictest--from-beginning

二者通话的结果图：

7.删除topic

1)kafka-topics.sh--delete--zookeeperhost:port--topictopicname
2)删除kafka存储目录（server.properties文件log.dirs配置，默认为"/tmp/kafka-logs"）相关topic目录删除zookeeper"/brokers/topics/"目录下相关topic节点