kafka集群配置之kafka启动了创建topic报错:Replication factor: 1 larger than avail
大家好, 我是上白书妖!
知识源于积累,登峰造极源于自律
今天我根据以前所以学的一些文献,笔记等资料整理出一些小知识点,有不当之处,欢迎各位斧正
kafka启动了创建topic报错:Replication factor: 1 larger than available brokers: 0
[shangbaishuyao@Hadoop102 kafka]$ jps
10382 Jps
7758 QuorumPeerMain
[shangbaishuyao@Hadoop102 kafka]$ bin/kafka-server-start.sh -daemon config/server.properties
[shangbaishuyao@Hadoop102 kafka]$ jps
10656 Jps
7758 QuorumPeerMain
10623 Kafka
[shangbaishuyao@Hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --create --replication-factor 3 --partitions 1 --topic first
Error while executing topic command : replication factor: 3 larger than available brokers: 1
[2020-03-21 10:26:36,741] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: replication factor: 3 larger than available brokers: 1(kafka.admin.TopicCommand$)
[shangbaishuyao@Hadoop102 kafka]$
这究竟是什么原因呢?
网上查了,有许多的原因:
比如这位网友的:
有比如这位网友的说法
但是这些都是不是我的原因
我刚刚经历了安装CM上找了三天的bug的我,今天又栽了在安装上,我命苦啊!!!..此处哭泣好多好多天…
终于,我发现了一个和别人不一样的出错的地方,瞬间感觉想飞起来…呜哈哈哈哈…
我查看了一下我的配置信息
#broker的全局唯一编号,不能重复
broker.id=0
#删除topic功能使能
delete.topic.enable=true
#处理网络请求的线程数量
num.network.threads=3
#用来处理磁盘IO的现成数量
num.io.threads=8
#发送套接字的缓冲区大小
socket.send.buffer.bytes=102400
#接收套接字的缓冲区大小
socket.receive.buffer.bytes=102400
#请求套接字的缓冲区大小
socket.request.max.bytes=104857600
#kafka数据存放的路径
log.dirs=/opt/module/kafka/data
#topic在当前broker上的分区个数
num.partitions=1
#用来恢复和清理data下数据的线程数量
num.recovery.threads.per.data.dir=1
#segment文件保留的最长时间,超时将被删除
log.retention.hours=168
#配置连接Zookeeper集群地址
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181
图示:
终于,我发现,虽然我这个配置没有任何问题,虽然我的kafka群起脚本也是这么写的也没有任何问题,按照这种配置看似完美,完美到,你的kafka能起来,但是往往看似完美的地方他就偏不让人省心,所以我抱着试试的心态将此处改为ip地址号
如图所示:
终于,我误打误撞找到了解决方法,开心的想要飞起来~~~~
然后就成功啦
结束寄语: 知识源于积累,登峰造极源于自律
kafka集群配置之kafka启动了创建topic报错:Replication factor: 1 larger than avail相关推荐
- kafka、zookeeper正常启动,创建topic:报错Replication factor: 3 larger than available brokers: 0
1.问题描述 新启用了一个集群,正常启动kafka和zookeeper后,jps查看所有节点kafka和zookeeper都正常工作. 当使用命令行创建topic时 ./kafka-topics.sh ...
- ELK5.3+Kafka集群配置
[一]资源准备 # 3台4C*8G, 安装Zookeeper.Kafka.Logstash--Broker(input: filebeat; output: Kafka) 10.101.2.23 10 ...
- kafka创建topic报错
kafka创建topic报错 kafka-topics.sh \ --zookeeper mypc01:2181,mypc02:2181,mypc03:2181/kafka-2020 \ --crea ...
- 【kafka】Kafka 集群配置SASL+ACL
1.概述 转载:https://www.cnblogs.com/xiao987334176/p/10110389.html 想根据这个做个试验,但是现在不行试试.以后用的时候试试 一.简介 在Kafk ...
- 汽车位置服务之kafka集群配置注意事项
1) 重复消费问题. 问题描述 采用kafka读取消息进行处理时,consumer会重复读取afka队列中的数据. 问题原因 kafka的consumer消费数据时首先会从broker里读取一批 ...
- kafka 集群_单机版kafka集群部署
前言 分布式消息队列是大型分布式系统不可缺少的中间件,主要解决应用耦合.异步消息.流量削锋等问题.实现高性能.高可用.可伸缩和最终一致性架构. 今天跟大家讲解下如何部署单机Kafka集群,希望大家喜欢 ...
- 云原生 | Kubernetes - k8s集群搭建(kubeadm)(持续收录报错中)
目录 前置 1.实现效果 2.环境准备 3.系统初始化 关闭防火墙 关闭 selinux 关闭 swap 主机名 配置hosts 将桥接的 IPv4 流量传递到 iptables 的链 时间同步 部署 ...
- kafka集群配置(三台机器)
前提:kafka基于zookeeper配置 解压安装包 ###将压缩包压缩到指定位置tar -zxvf kafka_2.11-1.01.tgz -C /usr/local/src/ 改名 mv kaf ...
- 【Kafka】kafka 创建 topic的时候 Replication factor 参数理解
1.概述 1.1 Partitions与Replication Factor调整准则 Partition 数目与Replication Factor是在创建一个topic时非常重要的两个参数,这两个参 ...
最新文章
- 记asp.net VB与C# 页面参数传值
- Flutter 插件url_launcher简介及使用,打开外部浏览器,拨打电话,发送短信,打开微信,支付宝,qq等
- python autoit获取网页ajax数据_WebDriver + Python 调用AutoIt例子(实现139邮箱写信页的附件上传)...
- mysql 硬盘缓存_paip.mysql性能跟iops的以及硬盘缓存的关系_MySQL
- XEngine:深度学习模型推理优化
- 微信小程序上传头像,使用wx.chooseImage; wx.uploadFile
- 安卓渗透测试工具——drozer安装使用教程
- C语言match函数的定义与用法,Match函数的基本用法
- 弘辽科技:淘宝商品入池怎么设置?技巧有哪些?
- Ajax中readyState和status
- unity制作火焰效果
- CSS的文本属性阴影效果
- python做后端的优势_python做后端好吗
- scoop下载安装教程,无报错,超简单。
- 禁止vite打包时将rgba转为16进制
- 产品经理不再纸上谈兵——雾里看花的用户画像
- Linux打印相关命令
- 【项目介绍】ElasticSearch7+Spark 构建高相关性搜索服务千人千面推荐系统
- ABAP 中长文本处理(此例利用长文本特性开发简历模板)CL_GUI_TEXTEDIT
- 对于网站过度SEO优化会有哪方面的搜索引擎原理
热门文章
- matlab网页制作代码
- SAP标准成本维护的三种取数方式来源
- 三年级信息技术用计算机打字教案,三年级下册信息技术教案-4.打字练习乐趣多|人教版(2015).doc...
- flash as3.0 五子棋的游戏制作
- VHDL D触发器 4位移位寄存器 例化+仿真(功能时序)
- My rating is 1064.详解
- 机器学习——朴素贝叶斯(Naive Bayes)详解及其python仿真
- golang slice扩容机制
- Flask框架中url_for用法详解
- Yupoo(又拍网)的系统架构