Ubuntu安装kafka基础使用
- kafka 安装环境
- 基础安装
- 下载kafka
- 解压文件
- 修改配置文件
- 启动kafka
- 创建主题
- 查看主题
- 发送消息
- 接收消息
- 工具测试
- kafka Assistant 工具连接测试
- 基础连接
- 连接成功
- 查看topic
- 查看消息
- 查看分区
- 查看消费组
- Idea 工具测试
- 基础信息
- 配置信息
- 当前消费组
- 发送消息
- 消费消息
- 参考博文
kafka 安装环境
基础安装
kafka 安装需要先安装java、zookeeper，此处默认已具备。
下载kafka
浏览器直接访问下载：
https://dlcdn.apache.org/kafka/
或者直接命令下载
wget https://dlcdn.apache.org/kafka/3.6.0/kafka_2.12-3.6.0.tgz解压文件
# 解压
tar -zxvf kafka_2.12-3.6.0.tgz
# 重命名
mv kafka_2.12-3.6.0 kafka
# pwd 查看基础路径
修改配置文件
# 配置文件路径
kafka/config
# vim server.properties
log.retention.hours=48 #数据最多保存48小时
log.retention.bytes=1073741824 #数据最多1G
log.dirs=/home/gl/middleware/kafka/kafka-logs #修改日志文件路径
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092启动kafka
# 1. 先启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &
# 2.启动kafka
bin/kafka-server-start.sh config/server.properties &
# 查看进程
ps -ef | grep zookeeper
ps -ef | grep kafka
创建主题
bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test --partitions 2 --replication-factor 1查看主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
发送消息
#发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test接收消息
# 接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning工具测试
kafka Assistant 工具连接测试
基础连接
连接成功
查看topic
查看消息
查看分区
查看消费组
Idea 工具测试
基础信息
配置信息
当前消费组
发送消息
消费消息
参考博文
- ubuntu20.04下Kafka安装与部署
- 如何在 Unbuntu 下安装 Apache Zookeeper 2020 最新教程