栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

【Linux安装kafka和依赖】

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【Linux安装kafka和依赖】

Linux安装Kafka和依赖: 一.安装jdk
    1.cd /usr/local
    2.mkdir java 创建java文件夹
    3.把jdk安装包jdk-8u144-linux-x64.tar.gz上传到/usr/local/java文件夹内
    4.在/usr/local/java目录执行tar -zxvf jdk-8u144-linux-x64.tar.gz
    5.配置环境变量
        ①:vim /etc/profile在文件末尾加上如下配置:
                 JAVA_HOME=/usr/local/java/jdk1.8.0_144
                 CLASSPATH=$JAVA_HOME/lib/
		         PATH=$PATH:$JAVA_HOME/bin
	             export PATH JAVA_HOME CLASSPAT
             然后wq保存退出
        ②:执行: source /etc/profile命令使配置生效   	     
        ③:查看是否安装成功:java -version
二.安装zookeeper
 	  1.下载版本: https://mirrors.bfsu.edu.cn/apache/zookeeper/
      2.tar -zxvf 文件名称 解压版本
      3.进入文件:cd 文件名/conf 
      4.将zoo_sample.cfg这个文件复制为zoo.cfg  : cp zoo_sample.cfg  zoo.cfg
      5.进行修改:dataDir默认地址是/tmp/zookeeper 数据存放地址可以随便写(前提是有这个文件)
      6.进入zookeeper下的bin目录执行启动:./zkServer.sh start
三.安装kafka
      1.下载kafka版本:https://mirrors.bfsu.edu.cn/apache/kafka/
      2.解压kafka包:tar -xzf 包名
      3.启动kafka之前要确保zookeeper已经启动
      4.启动kafka之前,需要修改kafka配置文件中的zookeeper地址
      5.vi config/server.properties 修改zookeeper.connect=127.0.0.1:2081(这里修改成自己安装的zookeeper地址和端口即可)
四. 命令 1.启动命令:

启动zooleeper:./zkServer.sh start 到zooleepr文件下运行kafka:bin/kafka-server-start.sh config/server.properties后台运行 kafka命令:bin/kafka-server-start.sh -daemon config/server.properties(切到kafka文件下) 2.查询kafka命令

创建topic(4个分区,2个副本): bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic testkafka版本 >= 2.2: bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test分区扩容 kafka版本 < 2.2: bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --partitions 2kafka版本 >= 2.2: bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic topic1 --partitions 2删除topicbin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test查询集群描述: bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181查询集群描述二:bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic foo --describetopic列表查询: bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/768461.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号