阿里云Ubuntu系统安装/简单使用Kafka

一、安装kafka

1.下载安装包

1.1下载地址

https://kafka.apache.org/downloads
注意： 版本可以随意选择，我们选择版本为2.4.1

2.压缩文件上传/解压

2.1上传

2.2解压文件

#解压文件指令
tar -zxvf kafka_2.12-2.4.1.tgz -C /export/server/
#创建软链接
ln -s /export/server/kafka_2.12-2.4.1/ /export/server/kafka

2.3配置server.properties

#进入配置目录
cd /export/server/kafka/config
#修改文件server.properties
vi server.properties
#指定bind的ID
broker.id=0
#指定日志数据存储位置
log.dirs=/export/server/kafka/data

2.4配置环境变量

#修改环境变量文件
vi /etc/profile
#文件末尾添加
export KAFKA_HOME=/export/server/kafka
export PATH=$PATH:$KAFKA_HOME/bin
#资源刷新
source /etc/profile

2.5启动服务

#启动zookeeper
zookeeper-server-start.sh /export/server/kafka/config/zookeeper.properties &
#启动kafka
kafka-server-start.sh /export/server/kafka/config/server.properties &
#测试
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list

2.6远程连接开启

2.6.1可以看我阿里云ubuntu系统安装mysql8.0提到的远程连接，操作步骤相同；

2.6.2差异性配置server.properties

#进入配置目录
cd /export/server/kafka/config
#修改文件server.properties
vi server.properties
#配置允许访问IP
listeners=PLAINTEXT://0.0.0.0:9092
#配置指向IP
advertised.listeners=PLAINTEXT://服务器IP:9092

二、简单使用Kafka

#创建一个主题
kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
#生产者发送消息
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
#消费者消费
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning