一、集群安装

1. Kafka下载：

wget https://archive.apache.org/dist/kafka/0.8.1/kafka_2.9.2-0.8.1.tgz

解压 tar zxvf kafka_2.9.2-0.8.1.tgz

kafka使用scala编写，需要下载scala相关的库

2.下载安装sbt：

wget http://repo.scala-sbt.org/scalasbt/sbt-native-packages/org/scala-sbt/sbt/0.13.1/sbt.rpm

$ rpm -ivh sbt.rpm

3. 更新scala环境：

sbt update

sbt package

#sbt assembly-package-dependency (sbt sbt-dependency) 不同版本命令不一致，这条命令也可以不执行

4. 配置config/server.properties

broker.id为依次增长的：0、1、2、3、4，集群中唯一id

log.dirs设置到大硬盘路径下

num.network.threads

num.partitions ，默认分区数

num.io.threads 建议值为机器的核数；

zookeeper.connect 设置为zookeeper Servers 列表，各节点以逗号分开；

5.在kafka的部署目录下，在各个节点上通过如下命令来启动：

$ nohup bin/kafka-server-start.sh config/server.properties &

6.使用jps命令可以查看，kafka 的 broker 服务是否打开

二、常用命令

创建Topic

bin/kafka-topics.sh --zookeeper CentOS-server1:2181,CentOS-server2:2181,CentOS-server3:2181 --topic mytopic --replication-factor 1 --partitions 1 --create

Topic列表

bin/kafka-topics.sh --zookeeper CentOS-server1:2181,CentOS-server2:2181,CentOS-server3:2181 --list

生产者测试

bin/kafka-console-producer.sh --broker-list CentOS-cm:9092,CentOS-server4:9092 --topic mytopic

消费者测试

bin/kafka-console-consumer.sh --zookeeper CentOS-server1:2181,CentOS-server2:2181,CentOS-server3:2181 --topic topicName --from-beginning

三、异常处理

报异常：

Failed to load class "org.slf4j.impl.StaticLoggerBinder"

解决方法：

下载slf4j-1.7.6.zip

wget http://www.slf4j.org/dist/slf4j-1.7.6.zip

解压

unzip slf4j-1.7.6.zip

把slf4j-nop-1.7.6.jar 包复制到kafka libs目录下面