环境:
centos 7 x64
kafka_2.11-2.4.0.tgz
apache-zookeeper-3.5.8-bin.tar.gz
jdk-8u191-linux-x64.tar.gz
- 安装jdk
解压:
tar -zxvf jdk-8u191-linux-x64.tar.gz -C ../install/
修改环境变量:
vim /etc/profile
增加
export JAVA_HOME=/opt/install/jdk1.8.0_191
export PATH=$PATH:$JAVA_HOME/bin
刷新配置文件:
source /etc/profile
验证:
java -version
- 安装zk
解压: ...
创建配置文件, zk提供了一个样本, 复制重命名就好:
cd apache-zookeeper-3.5.8-bin/conf/
cp zoo_sample.cfg zoo.cfg
启动:
cd ../bin
./zkServer.sh start
验证:
ps -ef | grep zookeeper
- 安装kafka
解压: ...
修改配置文件:
cd kafka_2.11-2.4.0/config/
vim server.properties
先修改如下:
listeners=PLAINTEXT://私有ip:9092
advertised.listeners=PLAINTEXT://公网ip:9092
zookeeper.connect=localhost:2181
- 简单使用
1. 启动kafka
bin/kafka-server-start.sh config/server.properties &
kafka启动默认占用1G的内存, 若内存不够
可编辑kafka-server-start.sh中的export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" 这一行
2. 停止kafka
bin/kafka-server-stop.sh
3. 创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic first-topic
4. 查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
5. 发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first-topic
进入发送消息的命令行
6. 接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first-topic --from-beginning
image.png
image.png
