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

Kafka手册

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

Kafka手册

1.安装

tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz //解压zookeeper安装包

tar –zxvf kafka_2.12-2.6.0.tgz //解压kafka安装包

这里需要修改配置文件,为了后续方便,可以将zookeeper解压的配置文件拷贝到kafka的config文件夹中,具体修改配置项有zookeeper数据存放路径,日志路径,以及具体ip;

Zookeeper配置文件zookeeper.properties修改如下:

Kafka的配置文件,server.properties修改如下:

由于zookeeper涉及到apache,需要java环境,运行环境还需要安装jdk,直接解压到指定目录:/usr/java/,接着需要设置环境变量:

       export LD_LIBRARY_PATH=/soft/lib36:$LD_LIBRARY_PATH

       export JAVA_HOME=/usr/java/jdk1.8.0_65

       export JRE_HOME=${JAVA_HOME}/jre

       export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib

       export PATH=.:$JAVA_HOME/bin:/soft/lib36:/iHyperDB/library:$PATH:$KE_HOME/bin

  1. 集群

当涉及到集群,安装步骤都一致,额外需要的是新建文件myid,其中写上brokeid+1的对应值即可,这里的myid就相当于一个标识,让集群中的kafka与zookeeper互相认识。

  1. 启停

cd /opt/kafka/kafka_2.12-2.6.0  //进入kafka安装目录

bin/zookeeper-server-start.sh –daemon config/zookeeper.properties  //启动zookeeeper

bin/zookeeper-server-stop.sh -daemon config/zookeeper.properties  //停止zookeeper

bin/kafka-server-start.sh -daemon config/server.properties       //启动kafka

bin/kafka-server-stop.sh -daemon config/server.properties       //停止kafka

  1. Topic创建

Kafka的主题创建有两种方式,命令行与代码创建。命令行创建需要进入bin目录:

./kafka-topics.sh –create –zookeeper ip:2181 – replication-factor 1 –partions 1 –topic test

查看主题:

./kafka-topics.sh –list –zookeeper ip:2181

如果是单个kafka,代码创建即可,涉及到集群,建议还是通过命令行创建Topic更为稳妥。

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

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

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