您当前的位置: 首页 >  centos

奋斗的工程师

暂无认证

  • 1浏览

    0关注

    97博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

centos安装ZooKeeper和kafka

奋斗的工程师 发布时间:2022-03-22 13:47:22 ,浏览量:1

A Zookeeper安装与配置 一:下载zookeeper安装包 从官网下载:http://mirrors.hust.edu.cn/apache/zookeeper/ 二:上传并配置zookeeper 1.放在/usr/local目录下并解压。 tar -zxvf zookeeper-3.4.13.tar.gz 即zookeeper路径为:/usr/local/zookeeper-3.4.13/zookeeper-3.4.13 2.进入/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/conf目录下 将zoo_sample.cfg复制一份取名为zoo.cfg cp zoo_sample.cfg zoo.cfg 编辑zoo.cfg文件 vi zoo.cfg 内容为: dataDir=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/data clientPort=2181 注:如果没有data文件请创建一个。 3.启动zookeeper 进入zookeeper的bin目录下 cd  /usr/local/zookeeper-3.4.13/zookeeper-3.4.13/bin 启动zookeeper ./zkServer.sh start 注:如果提示权限不够,可以修改此文件权限即: chmod 777 ./zkServer.sh 再次执行 ./zkServer.sh start 4.查看zookeeper启动状态 ./zkServer.sh status 5.将zookeeper修改为开机启动 (1)进入到/etc/rc.d/init.d目录下 cd  /etc/rc.d/init.d (2)创建一个zookeeper的文件,并编辑 touch zookeeper vi zookeeper 内容: #!/bin/bash   #chkconfig: 2345 10 90   #description: service zookeeper   export  JAVA_HOME=/usr/local/java/jdk1.8.0_191   export  ZOO_LOG_DIR=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/logs  ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13   su    root    ${ZOOKEEPER_HOME}/bin/zkServer.sh      "$1"  然后保存退出。 (3)给zookeeper文件添加可执行权限 chmod  +x  /etc/rc.d/init.d/zookeeper (4)把zookeeper这个脚本添加到开机启动项里面 chkconfig  --add  zookeeper (5)重启linux reboot (6)查看zookeeper是否启动 service  zookeeper  status B kafka安装与配置 一:从官网下载安装包 下载地址: http://archive.apache.org/dist/kafka/0.8.1.1/kafka_2.10-0.8.1.1.tgz 二:安装和配置kafka 1.解压kafka压缩包并放到/usr/local下 tar -xzf kafka_2.10-0.8.1.1.tar.gz 路径为:/usr/local/kafka_2.10-0.8.1.1 2.配置server.properties文件 cd /usr/local/kafka_2.10-0.8.1.1/config vim server.properties 修改属性为:zookeeper.connect=localhost:2181 3.启动kafka cd /usr/local/kafka_2.10-0.8.1.1/bin ./kafka-server-start.sh -daemon ../config/server.properties 4.创建topic cd /usr/local/kafka_2.10-0.8.1.1/bin ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 5.验证topic是否创建成功 cd /usr/local/kafka_2.10-0.8.1.1/bin ./kafka-topics.sh --list --zookeeper localhost:2181 6.查看topic描述 ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test 7.发送消息 ./kafka-console-producer.sh --broker-list localhost:9092 --topic test 8.接收消息 ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 3A网络科技致力于提供最稳定最快速的云服务器建设,通过高速的cn2线路显著提升网络速度,搭配企业级硬件设备竭诚为客户提供高效且可靠的服务器应用方案,加上十几年专业团队的协作来保障服务器的高质量以及超高安全性。

关注
打赏
1664290766
查看更多评论
立即登录/注册

微信扫码登录

0.0382s