Kafka笔记-Kafka集群搭建
如下有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集群搭建相关推荐
- kafka高可用集群搭建
################################################################# 物理环境(两台机子组成的真实集群): Desktop一个zk节点 L ...
- kafka简介与集群搭建
Kafka 是一款分布式消息发布和订阅系统,具有高性能.高吞吐量的特点而被 广泛应用与大数据传输场景. 由于 kafka 具有更好的吞吐量.内置分区.冗余及容错性的优点(kafka 每秒可 以处理几十 ...
- Kubernetes--学习笔记-4-Kubernetes 集群搭建过程中常用命令
一,查看版本信息 检查错误日志 journalctl -xe tail -f /var/log/messages 查看某个pod详细 kubectl describe pods/<pod名称&g ...
- 【Kafka】Kafka3.3.1集群搭建指南KRaft版本
目录 一.背景和描述 二.资源情况 三.技术选型 四.部署Kraft版本集群 五.配置SSL模式 六.Springboot使用SSL集成 参考资料 一.背景和描述 考虑资源安全性,需要搭建不依赖Zoo ...
- 2021年大数据Kafka(三):❤️Kafka的集群搭建以及shell启动命令脚本编写❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 Kafka的集群搭建以及shell启动命令脚本编写 一.搭建 ...
- java kafka 集群消费_kafka集群搭建和使用Java写kafka生产者消费者
转自:http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群 搭建在110, 111,112 2.kafka使 ...
- Kafka:ZK+Kafka+Spark Streaming集群环境搭建(九)安装kafka_2.11-1.1.0
如何搭建配置centos虚拟机请参考<Kafka:ZK+Kafka+Spark Streaming集群环境搭建(一)VMW安装四台CentOS,并实现本机与它们能交互,虚拟机内部实现可以上网.& ...
- Kafka:ZK+Kafka+Spark Streaming集群环境搭建(二十一)NIFI1.7.1安装
一.nifi基本配置 1. 修改各节点主机名,修改/etc/hosts文件内容. 192.168.0.120master192.168.0.121slave1192.168.0.122 slave2 ...
- kafka之四:Kafka集群搭建
1.软件环境 1.linux一台或多台,大于等于2 2.已经搭建好的zookeeper集群 3.软件版本kafka_2.11-0.9.0.1.tgz 2.创建目录并下载安装软件 #创建目录 cd /o ...
最新文章
- 10月份机房技术指标
- 英伟达显卡功率(频率)锁死
- python arma_Python ARIMA
- 更改mssql数据库的名字
- JavaScript里的循环方法:forEach,for-in,for-of
- div超出不换行_DIV元素不换行
- CVE-2017-11882漏洞分析
- 大数据,TB、PB、EB
- 创建MySQL数据库的副本_MySQL创建数据库(CREATE DATABASE语句)
- Atitit 常见每日流程日程日常工作.docx v9 每次pertime Atitit 常见每日每天流程日程日常工作 v9 raf attilax总结分享.docx Ver history i
- 计算机网络第七版第一章答案
- 【】论晚睡晚起的危害
- Guass(高斯消元+模板)
- 值得收藏:一份非常完整的MySQL规范
- html中楷书的格式,中国书法的书写格式
- NetBeans ide操作流程及注意事项
- 深度学习三巨头也成了大眼萌,这个一键转换动画电影形象的网站「太火」了...
- 最详细教程:Zotero和Better BibTeX安装,以及如何在R markdown中引用文献
- HIT信息安全概论复习:1~10
- 微信H5开发之页面布局
热门文章
- 一些总是记不住又容易搞混淆的东西(不断更新)
- VMware8 8.0.1 安装Lion正式版 原版镜像 直接DMG安装 非整合版 免引导 完美解决iCloud...
- MySQL 数据库怎样把一个表的数据插入到另一个表
- WSARecv参数lpNumberOfBytesRecvd的一个变态问题
- 面试官:我们只想要这样的C++工程师
- 2020年什么编程语言最受欢迎,待遇最高?
- 程序员熬夜写代码,用C/C++打造一个安全的即时聊天系统
- 每个前端开发者都要理解页面的渲染
- 最简易上手的Numpy学习笔记一
- 对层级聚类树进行模块分割,定位基因在哪个模块中