zhaoyu@home:~$

kafka安装

kafka安装

下载:

wget http://mirrors.hust.edu.cn/apache/kafka/1.1.0/kafka_2.11-1.1.0.tgz

然后解压:

tar -xzvf kafka_2.11-1.1.0.tgz

修改系统的环境变量:

vi /etc/profile

在前面添加:

export KAFKA_HOME=/opt/kafka_2.11-1.1.0 
export PATH=$PATH:$KAFKA_HOME/bin

生效系统环境变量

source /etc/profile

启动kafka server:

kafka使用ZooKeeper,如果没有启动Zookeeper,那么首先启动kafka内部的zookeeper。

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

然后启动kafka服务。

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

这里,kafka默认启动时设置的堆内存大小为1g。如果你的内存没有1g可用,会报出内存不出的错误,通过下面的命令调整堆内存的大小。

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"