单机zk+kafka环境搭建

只讲操作,不讲原理,不带说明。

PS:如果下面例子中给出的镜像地址不能用的话,就去官网找最新版

机器&java环境

  • 准备1台centos机器
  • 配置java环境

zookeeper 配置

  • 创建一个你想要安装 zookeeper 的工作目录。
  • 创建一个你想要保存 zookeeper 数据的工作目录。
  • zookeeper 下载:wget https://dlcdn.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
  • zookeeper 解压:tar -zxvf zookeeper......tar.gz
  • 配置环境变量
    • export ZOOKEEPER_INSTALL=/home/你的zk安装路径
    • export PATH=$PATH:$ZOOKEEPER_INSTALL/bin
  • 修改配置文件(conf目录)
    • 进入conf目录:cd zookeeper-3.3.6/conf
    • 创建配置文件:cp zoo_sample.cfg zoo.cfg
    • 配置 zoo.cfg
      • dataDir 改到一个单独的目录下,自己定义就好。
      • 加一行配置:server.1=本机ip地址:2888:3888
  • 服务管理(bin目录)
    • 进入bin目录:./zkServer.sh start 启动zk。
    • 查看zk服务状态:sh zkServer.sh status
    • 连接zk
      • 本地:./zkCli.sh
      • 远程:./zkCli.sh -server 你要连接的远程ip地址:端口
    • 关闭zk:sh bin/zkServer.sh stop
    • 重启zk:sh bin/zkServer.sh restart

ps:zookeeper 下载地址可以直接去官网找,记得找带 -bin 后缀的,不然会报错”找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain“。

kafka

  • 创建一个你想要安装 kafka 的工作目录。
  • 创建一个你想要保存 kafka 数据的目录和日志目录。
  • kafka下载:wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
  • kafka解压:tar -zxvf kafka......tgz
  • 配置环境变量:
    • export KAFKA_INSTALL=/home/你的kafka安装路径
    • export PATH=$PATH:$KAFKA_INSTALL/bin
  • 修改配置文件(config目录)
    • 进入config目录:cd config
    • 修改 server.properties 文件:vim server.properties
      • log.dirs 改成你自己创建的日志存储目录。
      • 加一行端口配置:port=9092
  • 服务管理(bin目录)
    • 前台启动kafka:sh kafka-server-start.sh ../config/server.properties
    • 后台启动kafka:sh kafka-server-start.sh ../config/server.properties &./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
    • 查看kafka运行状态:jps
    • 关闭kafka:kafka-server-stop.sh
  • 来跑个demo(bin目录)
    • 创建一个topic(名为test):sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    • 查看 topic 列表:sh kafka-topics.sh --list --zookeeper localhost:2181
    • 创建 producer:sh kafka-console-producer.sh --broker-list localhost:9092 --topic test
    • 创建 consumer:sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    • 在 producer 控制台输入消息回车发送,consumer 控制台可以查看到。

ps:kafka 下载地址可以去官网找,带 src 后缀的需要编译、不带 src 的不需要编译。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 一、入门1、简介Kafka is a distributed,partitioned,replicated com...
    HxLiang阅读 8,792评论 0 9
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,323评论 19 139
  • Kafka入门经典教程-Kafka-about云开发 http://www.aboutyun.com/threa...
    葡萄喃喃呓语阅读 13,691评论 4 54
  • 又要搬家了,房子不合规范整修,不能住了,最多这个星期,或者下个星期,钱刚好还给朋友了,又办了健身卡,恰巧又在学习英...
    一直走别回头M阅读 12,245评论 1 2
  • “我可能不会爱你”里面,李大仁形容程又青是一本书,一本让人一读再读的书。 我常常想那是一种什么样的感情,让两个人认...
    Jinggao阅读 4,381评论 0 0