大家好, 我是上白书妖!

知识源于积累,登峰造极源于自律

今天我根据以前所以学的一些文献,笔记等资料整理出一些小知识点,有不当之处,欢迎各位斧正

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相关推荐

  1. kafka、zookeeper正常启动,创建topic:报错Replication factor: 3 larger than available brokers: 0

    1.问题描述 新启用了一个集群,正常启动kafka和zookeeper后,jps查看所有节点kafka和zookeeper都正常工作. 当使用命令行创建topic时 ./kafka-topics.sh ...

  2. ELK5.3+Kafka集群配置

    [一]资源准备 # 3台4C*8G, 安装Zookeeper.Kafka.Logstash--Broker(input: filebeat; output: Kafka) 10.101.2.23 10 ...

  3. kafka创建topic报错

    kafka创建topic报错 kafka-topics.sh \ --zookeeper mypc01:2181,mypc02:2181,mypc03:2181/kafka-2020 \ --crea ...

  4. 【kafka】Kafka 集群配置SASL+ACL

    1.概述 转载:https://www.cnblogs.com/xiao987334176/p/10110389.html 想根据这个做个试验,但是现在不行试试.以后用的时候试试 一.简介 在Kafk ...

  5. 汽车位置服务之kafka集群配置注意事项

    1)  重复消费问题. 问题描述  采用kafka读取消息进行处理时,consumer会重复读取afka队列中的数据. 问题原因  kafka的consumer消费数据时首先会从broker里读取一批 ...

  6. kafka 集群_单机版kafka集群部署

    前言 分布式消息队列是大型分布式系统不可缺少的中间件,主要解决应用耦合.异步消息.流量削锋等问题.实现高性能.高可用.可伸缩和最终一致性架构. 今天跟大家讲解下如何部署单机Kafka集群,希望大家喜欢 ...

  7. 云原生 | Kubernetes - k8s集群搭建(kubeadm)(持续收录报错中)

    目录 前置 1.实现效果 2.环境准备 3.系统初始化 关闭防火墙 关闭 selinux 关闭 swap 主机名 配置hosts 将桥接的 IPv4 流量传递到 iptables 的链 时间同步 部署 ...

  8. kafka集群配置(三台机器)

    前提:kafka基于zookeeper配置 解压安装包 ###将压缩包压缩到指定位置tar -zxvf kafka_2.11-1.01.tgz -C /usr/local/src/ 改名 mv kaf ...

  9. 【Kafka】kafka 创建 topic的时候 Replication factor 参数理解

    1.概述 1.1 Partitions与Replication Factor调整准则 Partition 数目与Replication Factor是在创建一个topic时非常重要的两个参数,这两个参 ...

最新文章

  1. 记asp.net VB与C# 页面参数传值
  2. Flutter 插件url_launcher简介及使用,打开外部浏览器,拨打电话,发送短信,打开微信,支付宝,qq等
  3. python autoit获取网页ajax数据_WebDriver + Python 调用AutoIt例子(实现139邮箱写信页的附件上传)...
  4. mysql 硬盘缓存_paip.mysql性能跟iops的以及硬盘缓存的关系_MySQL
  5. XEngine:深度学习模型推理优化
  6. 微信小程序上传头像,使用wx.chooseImage; wx.uploadFile
  7. 安卓渗透测试工具——drozer安装使用教程
  8. C语言match函数的定义与用法,Match函数的基本用法
  9. 弘辽科技:淘宝商品入池怎么设置?技巧有哪些?
  10. Ajax中readyState和status
  11. unity制作火焰效果
  12. CSS的文本属性阴影效果
  13. python做后端的优势_python做后端好吗
  14. scoop下载安装教程,无报错,超简单。
  15. 禁止vite打包时将rgba转为16进制
  16. 产品经理不再纸上谈兵——雾里看花的用户画像
  17. Linux打印相关命令
  18. 【项目介绍】ElasticSearch7+Spark 构建高相关性搜索服务千人千面推荐系统
  19. ABAP 中长文本处理(此例利用长文本特性开发简历模板)CL_GUI_TEXTEDIT
  20. 对于网站过度SEO优化会有哪方面的搜索引擎原理

热门文章

  1. matlab网页制作代码
  2. SAP标准成本维护的三种取数方式来源
  3. 三年级信息技术用计算机打字教案,三年级下册信息技术教案-4.打字练习乐趣多|人教版(2015).doc...
  4. flash as3.0 五子棋的游戏制作
  5. VHDL D触发器 4位移位寄存器 例化+仿真(功能时序)
  6. My rating is 1064.详解
  7. 机器学习——朴素贝叶斯(Naive Bayes)详解及其python仿真
  8. golang slice扩容机制
  9. Flask框架中url_for用法详解
  10. Yupoo(又拍网)的系统架构