如下有3台虚拟机,对应的IP如下:

下一台

下一台

对应的3给IP地址如下:

192.168.94.129

192.168.94.131

192.168.94.132

这里默认jdk 1.8是安装好了的。

首先是安装zookeeper,分布式部署,随后再部署kafka

解压后进入zookeeper,的conf。拷贝一份zoo_sample.cfg为zoo.cfg

修改zoo.cfg

上面3台服务器都是需要这样配置。并且再/tmp/zookeeper创建一个myid文件,写入server.x中的x,这个x。如192.168.94.129中myid为0,192.168.94.131中myid为1

在bin目录里面启动

./zkServer.sh start

这里会在conf下自动去找zoo.cfg文件

如果有问题会出现到

zookeep.out文件夹中记录出现的错误,有问题就查看这个文件。启动成功后。

上面每一台都要这么做。

输入./zkServer.sh status查看状态:

下面是搭建集群kafka

解压kafka后修改config下面的server.properties

添加如下数据:

broker.id=0
listeners=PLAINTEXT://192.168.94.129:9092
zookeeper.connect=192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181

这个broker.id=0为/tmp/zookeeper/myid的id。

再修改

meta.properties文件如下

把broker.id添加当前myid的值。

随后就可以启动kafka了。集群就搭建好了

在bin目录下./kafka-server-start.sh ../config/server.properties

这里报错信息会打印到前端,有问题要即使处理。

添加一个topic

./kafka-topics.sh --create --zookeeper 192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181 --partitions 3 --replication-factor 3 --topic HelloWorld

往topic里面添加消息

./kafka-console-producer.sh --broker-list 192.168.94.129:9092,192.168.94.131:9092,192.168.94.132:9092 --topic HelloWorld

就可以发送消息了:

随便找某一台进行消费

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic HelloWorld --from-beginning

Kafka笔记-Kafka集群搭建相关推荐

  1. kafka高可用集群搭建

    ################################################################# 物理环境(两台机子组成的真实集群): Desktop一个zk节点 L ...

  2. kafka简介与集群搭建

    Kafka 是一款分布式消息发布和订阅系统,具有高性能.高吞吐量的特点而被 广泛应用与大数据传输场景. 由于 kafka 具有更好的吞吐量.内置分区.冗余及容错性的优点(kafka 每秒可 以处理几十 ...

  3. Kubernetes--学习笔记-4-Kubernetes 集群搭建过程中常用命令

    一,查看版本信息 检查错误日志 journalctl -xe tail -f /var/log/messages 查看某个pod详细 kubectl describe pods/<pod名称&g ...

  4. 【Kafka】Kafka3.3.1集群搭建指南KRaft版本

    目录 一.背景和描述 二.资源情况 三.技术选型 四.部署Kraft版本集群 五.配置SSL模式 六.Springboot使用SSL集成 参考资料 一.背景和描述 考虑资源安全性,需要搭建不依赖Zoo ...

  5. 2021年大数据Kafka(三):❤️Kafka的集群搭建以及shell启动命令脚本编写❤️

    全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 Kafka的集群搭建以及shell启动命令脚本编写 一.搭建 ...

  6. java kafka 集群消费_kafka集群搭建和使用Java写kafka生产者消费者

    转自:http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群 搭建在110, 111,112 2.kafka使 ...

  7. Kafka:ZK+Kafka+Spark Streaming集群环境搭建(九)安装kafka_2.11-1.1.0

    如何搭建配置centos虚拟机请参考<Kafka:ZK+Kafka+Spark Streaming集群环境搭建(一)VMW安装四台CentOS,并实现本机与它们能交互,虚拟机内部实现可以上网.& ...

  8. Kafka:ZK+Kafka+Spark Streaming集群环境搭建(二十一)NIFI1.7.1安装

    一.nifi基本配置 1. 修改各节点主机名,修改/etc/hosts文件内容. 192.168.0.120master192.168.0.121slave1192.168.0.122 slave2 ...

  9. kafka之四:Kafka集群搭建

    1.软件环境 1.linux一台或多台,大于等于2 2.已经搭建好的zookeeper集群 3.软件版本kafka_2.11-0.9.0.1.tgz 2.创建目录并下载安装软件 #创建目录 cd /o ...

最新文章

  1. 10月份机房技术指标
  2. 英伟达显卡功率(频率)锁死
  3. python arma_Python ARIMA
  4. 更改mssql数据库的名字
  5. JavaScript里的循环方法:forEach,for-in,for-of
  6. div超出不换行_DIV元素不换行
  7. CVE-2017-11882漏洞分析
  8. 大数据,TB、PB、EB
  9. 创建MySQL数据库的副本_MySQL创建数据库(CREATE DATABASE语句)
  10. Atitit 常见每日流程日程日常工作.docx v9 每次pertime Atitit 常见每日每天流程日程日常工作 v9 raf attilax总结分享.docx Ver history i
  11. 计算机网络第七版第一章答案
  12. 【】论晚睡晚起的危害
  13. Guass(高斯消元+模板)
  14. 值得收藏:一份非常完整的MySQL规范
  15. html中楷书的格式,中国书法的书写格式
  16. NetBeans ide操作流程及注意事项
  17. 深度学习三巨头也成了大眼萌,这个一键转换动画电影形象的网站「太火」了...
  18. 最详细教程:Zotero和Better BibTeX安装,以及如何在R markdown中引用文献
  19. HIT信息安全概论复习:1~10
  20. 微信H5开发之页面布局

热门文章

  1. 一些总是记不住又容易搞混淆的东西(不断更新)
  2. VMware8 8.0.1 安装Lion正式版 原版镜像 直接DMG安装 非整合版 免引导 完美解决iCloud...
  3. MySQL 数据库怎样把一个表的数据插入到另一个表
  4. WSARecv参数lpNumberOfBytesRecvd的一个变态问题
  5. 面试官:我们只想要这样的C++工程师
  6. 2020年什么编程语言最受欢迎,待遇最高?
  7. 程序员熬夜写代码,用C/C++打造一个安全的即时聊天系统
  8. 每个前端开发者都要理解页面的渲染
  9. 最简易上手的Numpy学习笔记一
  10. 对层级聚类树进行模块分割,定位基因在哪个模块中