kafka安装

安装前提

• centos
• java环境
• zookeeper(也可以)
• 官网下载kafka并解压到指定目录

配置
修改kafka目录下的config/server.propertis

listeners=PLAINTEXT://localhost:9092
zookeeper.connect=localhost:2181

运行
打开两个终端
终端1运行生产者

[root@localhost kafka_2.12-2.1.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>1111111111111111111
>22222222222222222222222222
>333333333333333333333333333333
>44444444444444444444444444
>555555555555555555555555555

终端2运行消费者

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
1111111111111111111
22222222222222222222222222
333333333333333333333333333333
44444444444444444444444444
555555555555555555555555555

检查

[root@localhost kafka_2.12-2.1.0]# jps
27282 Jps
23667 Kafka
18836 QuorumPeerMain
26645 ConsoleConsumer
[root@localhost kafka_2.12-2.1.0]# 

开机启动

1. 进入目录，新建kafka

cd /etc/init.d/
vi kafka

2. 修改内容

#!/bin/bash
#chkconfig:2345 20 90 #description:kafka #processname:kafka 
case $1 in 
    start) 
        /path/to/kafka/bin/kafka-server-start.sh -daemon /path/to/kafka/config/server.properties ;; 
    stop) 
        /path/to/kafka/bin/kafka-server-stop.sh ;; 
    status) 
        jps ;; 
    restart) 
        /path/to/kafka/bin/kafka-server-stop.sh 
        /path/to/kafka/bin/kafka-server-start.sh -daemon /path/to/kafka/config/server.properties ;; 
    *) 
        echo "require start|stop|status|restart" ;; 
esac

3. 修改权限

chmod +x kafka

4. 测试命令

service kafka status

5. 添加到服务列表

chkconfig --add kafka

6. 验证

chkconfig --list

7. 设置为开机启动

chkconfig kafka on

集群
（等补充）