kafka安装流程
2024-09-08 03:56:28
本文是作者原创,版权归作者所有.若要转载,请注明出处.
安装前的环境准备
1.由于Kafka是用Scala语言开发的,运行在JVM上,在安装之前需要先安装JDK(省略)
2.kafka依赖zookeeper,所以需要先安装zookeeper,https://zookeeper.apache.org/releases.html
解压zookeeper,安装在/usr/local/java下
tar zxvf zookeeper-3.4.14.tar.gz
进入zk目录
cd zookeeper-3.4.14/
zookeeper的默认配置文件为/conf/zoo_sample.cfg,需要将其修改为zoo.cfg
cp conf/zoo_sample.cfg conf/zoo.cfg
进入zk的bin目录,启动zk服务端,查看zk状态,默认端口2181
cd /usr/local/java/zookeeper-3.4.14/bin
./zkServer.sh start
./zkServer.sh status
添加放行端口
firewall-cmd --zone=public --add-port=2181/tcp --permanent
重启防火墙
firewall-cmd --reload
查看已开放端口:
firewall-cmd --list-all
安装kafka
下载kafka(官网 http://kafka.apache.org/downloads),就按官方推荐的即可
1. 解压安装包,(前面2.12是Scala版本,后面2.4.1是kafka版本),安装在/usr/local/java下
tar zxvf kafka_2.12-2.4.1.tgz
2.修改配置文件 config/server.properties:
#broker.id属性在kafka集群中必须要是唯一 broker.id=0 #kafka部署的机器ip和提供服务的端口号 listeners=PLAINTEXT://localhost:9092 #kafka的消息存储文件 log.dir=/usr/local/java/data/kafka‐logs #kafka连接zookeeper的地址 zookeeper.connect=localhost:2181
3.进入kafka目录,后台启动kafka
bin/kafka-server-start.sh -daemon config/server.properties
4 可以用jps命令,查看有没有kafka的进程
5. 停止kafka服务
bin/kafka-server-stop.sh config/server.properties
6.添加放行端口
firewall-cmd --zone=public --add-port=9302/tcp --permanent
重启防火墙
firewall-cmd --reload
查看已开放端口:
firewall-cmd --list-all
Zk和kafka都启动完成后测试
以下测试命令都在kafka主目录下进行
1. 创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.查看主题
bin/kafka-topics.sh --list --zookeeper localhost:2181
3. 发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
4.接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
5. 查看特定主题的详细信息
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
6 删除主题
最新文章
- php的laravel框架快速集成微信登录
- sscanf提取字符串中的数据php
- gcc编译与gdb调试简要步骤
- 3ds max输出图片
- UIlabel 属性text
- 关于jsp中response.sendRedirect显示错误
- spring扫描classpath下特定package,并加载具有特定注解的接口
- Spring配置文件外部化配置及.properties的通用方法
- C++ sort函数
- 转:linux下Xampp安装与配置
- [AngularJS] 5 simple ways to speed up your AngularJS application
- css3动画与js动画的一些理解
- BZOJ 1103: [POI2007]大都市meg(dfs序,树状数组)
- Protobuf动态解析在Java中的应用 包含例子程序
- TCP/IP卷一:第一章
- 小米wifi
- beta冲刺5-咸鱼
- zoj 3950 how many nines
- Django-ORM-单表操作
- JS-面向对象编程-对象方法添加属性
热门文章
- mysql-创建用户报错ERROR 1396 (HY000): Operation CREATE USER failed for 'XXXX'@'XXXX'
- Oracle数据导入Mysql中
- oracle 常用语句3
- react第十七单元(redux和组件之间的通信,react-redux的相关api的用法)
- Python之selenium创建多个标签页
- Autofac官方文档翻译--一、注册组件--3属性和方法注入
- vscode常用快捷键和插件
- [leetcode]49. Group Anagrams重排列字符串分组
- springboot 启动jar正确方式
- android stdio 打包