一、安装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远程连接开启
可以看我阿里云ubuntu系统安装mysql8.0提到的远程连接,操作步骤相同;
二、简单使用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