Kafka安装和配置

JDK1.8安装

1. 下载，在Oracle下载linux版本的jdk1.8。我是在window下载，然后用rz命令传输到linux。
2. 解压

tar -zxvf jdk-8u171-linux-x64.tar.gz

移动位置

sudo mv jdk1.8.0_171 /usr/local/jdk1.8

3. 配置jdk

vim /etc/profile

然后配置

export JAVA_HOME=/usr/local/jdk1.8
export JRE_HOME={JAVA_HOME}/lib:{JAVA_HOME}/bin:$PATH

发现无法保存。保存的时候用:w !sudo tee %即可。
最后使用命令使配置生效

source /etc/profile

4. 检查是否安装配置成功

java -version

Zookeeper安装与配置

1. 下载并解压

wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz

tar -zxvf zookeeper-3.4.14.tar.gz

2. 修改配置

cd zookeeper-3.4.14/conf/

cp zoo_sample.cfg zoo.cfg

然后进入vim编辑

dataDir=/tmp/zookeeper/data
dataLogDir=/tmp/zookeeper/log

创建目录

mkdir /tmp/zookeeper

mkdir /tmp/zookeeper/data

mkdir /tmp/zookeeper/log

3. 修改环境变量

sudo vim /etc/profile

export ZOOKEEPER_INSTALL=/usr/local/zookeeper-3.4.14/
export PATH=.:${ZOOKEEPER_INSTALL}/bin:$PATH

然后source /etc/profile使其生效

4. 启动zk的Server端
   进入bin目录下执行

./zkServer.sh start

Kafka安装和配置

1. 下载安装和解压

sudo wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz

sudo tar -zxvf kafka_2.12-2.4.0.tgz

2. 启动

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

3. 创建topic (需要新开一个窗口

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

4. 启动producer和consumer

• 启动producer

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

• 启动consumer

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