一:  MAC安装kafka

安装：

kafka依赖java环境，因此你可能需要先安装好java环境。

// mac 环境使用brew直接安装kafka
brew install kafka 

// 卸载
brew uninstall kafka

mac 安装kafka过程中会自动的安装好zookeeper。

启动：

// 启动
brew services start kafka
brew services start zookeeper

// 重启
brew services restart kafka
brew services restart zookeeper

二：Linux安装kafka

一、进入官网下载安装包

http://kafka.apache.org/downloads

下载Binary包如下图，下面以2.1.0版本为例：

备注：此处有Source包和Binary包，此处需要选择Binary包。

cd /usr/src
// 下载包
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.12-2.2.0.tgz

// 解压
tar -xzf kafka_2.12-2.2.0.tgz
// 重命名为kafka
mv kafka_2.12-2.2.0 kafka

cd kafka

前台启动Zookeeper 和kafka

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

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

后台启动Zookeeper 和kafka

bin/zookeeper-server-start.sh config/zookeeper.properties 1>/dev/null  2>&1  &

bin/kafka-server-start.sh config/server.properties 1>/dev/null  2>&1  &

其中1>/dev/null 2>&1 是将命令产生的输入和错误都输入到空设备，也就是不输出的意思。/dev/null代表空设备。

kafka配置说明：

配置文件server.properties

// mac 电脑配置文件地址
vim /usr/local/etc/kafka/server.properties

// Linux 配置文件地址
vim /usr/src/kafka/config/server.properties

配置参考地址：

http://www.orchome.com/472

备注： 尽量配置host.name, 例如本地的配置

host.name = 127.0.0.1
port=9092

常用基本命令：

创建一个主题(topic)

// mac
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

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

删除topic

// mac 
kafka-topics  --delete --zookeeper localhost:2181 --topic 【topic name】

// linux 
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic 【topic name】

查看创建的topic list

// mac
kafka-topics --list --zookeeper localhost:2181

// linux
bin/kafka-topics.sh --list --zookeeper localhost:2181

生产消息

// mac 
kafka-console-producer --broker-list localhost:9092 --topic test

// linux 
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费消息

// mac 
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

// linux 
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

更多使用方式可参考：http://www.orchome.com/454