文章目录

前言

一、下载解压

二、配置

三、启动zookeeper

四、启动kafka

前言

kafka是一个高吞吐的分布式消息队列系统，采用发布/订阅消息模式，先进先出（FIFO）保证顺序，默认每隔7天清理数据。

常用场景：缓存/消峰、解耦和异步通信。

---

一、下载解压

#创建安装目录
mkdir /opt/kafka
	 
#移动到目录
cd /opt/kafka
	 
#下载kafka安装包
wget http://archive.apache.org/dist/kafka/0.8.2.1/kafka_2.11-0.8.2.1.tgz
	
#解压缩
tar -zxvf kafka_2.11-0.8.2.1.tgz

注意，kafka_2.11-0.8.2.1.tgz版本是已经编译好的版本，解压就能使用。

---

二、配置

#创建日志目录
mkdir /opt/kafka/log
	
#进入配置目录
cd /opt/kafka/kafka_2.11-0.8.2.1/config
	
#编辑配置文件
vi server.properties

    修改如下信息：

broker.id=0
#端口号
port=9092
#服务器IP地址，修改为自己的服务器IP
host.name=10.218.220.106
#日志存放路径，上面创建的日志目录
log.dirs=/opt/kafka/log
#zookeeper地址和端口，单机配置部署，localhost:2181
zookeeper.connect=localhost:2181 

---

三、启动zookeeper

        此kafka版本自带zookeeper，由于我们是单机部署，且量不是很大，所以自带的zookeeper完全能满足我们的需求。

#移到kafka目录
cd /opt/kafka/kafka_2.11-0.8.2.1/ 
#启动
bin/kafka-server-start.sh -daemon config/server.properties&

---

四、启动kafka

#移到kafka目录
cd /opt/kafka/kafka_2.11-0.8.2.1/bin/
	
#创建topic（创建主题：名称为“topicTest”、复制数目为1、partitions为1的topic主题）
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka_topic_test
	
#查看topic信息
./kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic topicTest
	
#查看已创建的主题
./kafka-topics.sh --list --zookeeper 127.0.0.1:2181
	
#启动生产者控制台
./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic topicTest
	
#启动消费者控制台（新开一个窗口）
./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic topicTest --from-beginning

名词解释：

1、replication-factor：复制数目，提供failover机制；1代表只在一个broker上有数据记录，一般值都大于1，代表一份数据会自动同步到其他的多个broker，防止某个broker宕机后数据丢失。

2、partitions：一个topic可以被切分成多个partitions，一个消费者可以消费多个partitions，但一个partitions只能被一个消费者消费，所以增加partitions可以增加消费者的吞吐量。kafka只保证一个partitions内的消息是有序的，多个partitions之间的数据是无序的。