首页 > 系统服务 > 详细

【linux-centos】安装kafka-2.8

时间:2021-06-06 21:16:59      阅读:15      评论:0      收藏:0      [点我收藏+]

21.6.6:安装kafka-2.8 

  说明:kafka 在设计上就是依赖于 zookeeper 的,所以启动 kafka 前需要启动 zookeeper


***zookeeper的安装:
  zookeeper依赖于jdk环境
***先安装jdk
    yum -y install java-1.8.0-openjdk-demo.x86_64
  #验证一下是否安装成功
    java -version

若java安装不成功,需要更换yum源
#备份初始源
#备份初始源配置
mv /etc/yum.repos.d/CentOS-Base.repo /etc/yum.repos.d/CentOS-Base.repo.backup
#下载新的阿里镜像源
wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
#清理和重建索引
yum clean all
yum makecache
***开始安装zookeeper
  wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

  tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz

  mv apache-zookeeper-3.7.0-bin /usr/local

  ln -s /usr/local/apache-zookeeper-3.7.0-bin /usr/local/zookeeper
  # 添加至环境变量
  echo export PATH=\"\$PATH:/usr/local/zookeeper/bin\" >> ~/.bashrc
  #更新环境变量
  source ~/.bashrc

  目录说明:
  /usr/local/apache-zookeeper-3.7.0-bin/bin 执行文件(.sh的文件是linux文件,.cmd文件是windows文件)
  /usr/local/apache-zookeeper-3.7.0-bin/conf 配置文件
  /usr/local/apache-zookeeper-3.7.0-bin/docs 文档
  /usr/local/apache-zookeeper-3.7.0-bin/lib jars包

  开始配置:
  cd /usr/local/zookeeper/conf
  cp zoo_sample.cfg zoo.cfg
  vim zoo.cfg
  tickTime=2000 #检测时间间隔
  initLimit=10 主从连接超时时间
  syncLimit=5 follower与leader同步超时时间
  dataDir=/usr/local/zookeeper/data 存储节点id、地址、数据快照
  clientPort=2181 对外服务的端口  
  maxClientCnxns=60 客户端对外连接的数量


  启动、关闭、状态、查看、连接
    启动:/usr/local/zookeeper/bin/zkServer.sh start
    关闭:/usr/local/zookeeper/bin/zkServer.sh stop
    状态:/usr/local/zookeeper/bin/zkServer.sh status
    查看启动:ps aux|grep zoo
    连接本机zoo:/usr/local/zookeeper/bin/zkCli.sh
    连接其他机器:zkCli.sh -server 192.168.74.128:2181

  配置集群版(更新中):
    zoo.cfg中
    server.1 = 192.168.74.129:28888:38888
    server.2 = 192.168.74.130:28888:38888
    server.3 = 192.168.74.131:28888:38888

***开始安装:

  1)官网:http://kafka.apache.org/downloads
  2)下载:https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz
  tar -zxvf kafka_2.13-2.8.0.tgz
  mv kafka_2.13-2.8.0 /usr/local/

  由于下载的是二进制包,所以解压后就算是安装好了,无需编译。
  kafka 在设计上就是依赖于 zookeeper 的,所以启动 kafka 前需要启动 zookeeper

  启动kafka:
  /usr/local/kafka_2.13-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.13-2.8.0/config/server.properties
  后台启动:
  nohup /usr/local/kafka_2.13-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.13-2.8.0/config/server.properties>>kafka.nohup &

  端口:

  创建topic:
  /usr/local/kafka_2.13-2.8.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  创建一个名为test的topic,1个分区,每个分区分配1个副本
  查看topic是否创建成功
  /usr/local/kafka_2.13-2.8.0/bin/kafka-topics.sh -list -zookeeper localhost:2181


  开始验证:
    从producer端发送消息
    查看consumer端接收到的消息

    producer端:
    /usr/local/kafka_2.13-2.8.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

    consumer端:
    /usr/local/kafka_2.13-2.8.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

    能正常发送消息,能正常接收消息证明搭建成功

【linux-centos】安装kafka-2.8

原文:https://www.cnblogs.com/shixiangqian/p/14856043.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!