在部署前需确保网络正常及已安装JDK和Zookeeper环境

zookeeper 最好也把IP给绑定上去 ClientPortAddress=x.x.x.x

部署Kafka

创建相关目录

mkdir -p /home/modfuncd /home/modfun

下载 Kafka

# 下载wget http://mirrors.shu.edu.cn/apache/kafka/1.1.1/kafka_2.11-1.1.1.tgz# 解压tar zxf kafka_2.11-1.1.1.tgz

创建kafka依赖目录

# 消息日志持久化目录mkdir -p /data/kafka/log

修改配置文件

cd kafka_2.11-1.1.1vim config/server.properties

修改内容如下

# 一次修改多台（集群）的borker.id 从 0 开始border.id=0# 解除注释listeners=PLAINTEXT://172.27.1.1:9092# 局域网对外互联网开放设置advertised.listeners=PLAINTEXT://172.27.1.1:9092# 修改主机名为本机内网IPhost.name=172.27.1.1# 设置处理消息最大值message.max.bytes=2000000fetch.message.max.bytes=2000000# 修改日志存放目录log.dirs=/data/kafka/log# 设置分区数，为Topic创建分区时，分区数最好是broker数量的整数倍，这样才能是一个Topic的分区均匀的分布在整个Kafka集群中num.partitions=3# 修改Zookeeper集群的IP和端口zookeeper.connect=172.27.1.1:2181,172.27.1.2:2181,172.27.1.3:2181# 添加启用删除topic配置delete.topic.enable=true

启动kafka

# 添加守护的方式启动bin/kafka-server-start.sh -daemon ./config/server.properties

停止kafka

kill -9 {pid}