记一次kafka无法生产发送消息排查经历

2023-10-31

参考,欢迎点击原文:https://stackoverflow.com/questions/37902167/kafka-error-while-fetching-metadata-with-correlation-id-leader-not-available(老外启示)
https://blog.csdn.net/wt1286331074/article/details/121033464(自己写的记录)
https://www.cnblogs.com/riches/p/11720068.html(结合springboot使用教程)

今天有空准备把关于kafka那块知识完善掉,之前是把他run起来了,还没有与spring boot结合起来使用

问题情况:
按照教程首先引入pom,然后自己引用kafkaTemplate,直接调用send方法基本就可以发送了,然而还是踩坑了,idea报WARN Error while fetching metadata with correlation id 1 : {TRAIL_TOPIC=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient),然后一直不断的重试
解决过程:

  1. 首先看到这个报错我看不太懂啥意思,第一反应就是找百度,然后百度给我整了一堆说传送门修改链接地址,那时我就纳闷了地址我之前就改好了呀,而且能起来了的
  2. 接着看到个国外老哥说的可能是需要配置下允许自动新增topic,emmm反正我是没找到哪里可以配置这个的,于是我按照命令行的形式在kafka容器里新建个topic:/opt/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.91.66:2181 --replication-factor 1 --partitions 1 --topic testTopic,发现成功是成功了,但是idea那依然报
  3. 这时我想就看日志吧,可能日志上有啥可以深究的,打开logs文件夹发现好多种日志类型,如图1-1,我就看了最有可能的server.log-11-15,看到基本都是这个报错如图1-2,这意思我懂,就是说不能连上broker,仔细一瞧发现ip是70结尾的,额。。。咱们公司分配的ip会变得,因为kafka配置时候使用的是固定ip,这个ip明显是上次用的,so,查看现在的ip,再重新run个新的容器就可以啦

1-1
1-2
总结:
这一次找这个问题花费了靠三个小时,其实反应快的三分钟就解决掉了,无非是,看容器日志,发现IP不对,解决。
以后长个记性吧

tip:最近发现csdn广告越来越多了,有些文章还要开会员才能看,太恶心了一点没有开源精神,决定晚点时候搬个家,csdn暂时先拜拜了~

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

记一次kafka无法生产发送消息排查经历 的相关文章

随机推荐

  • Web Worker 用法

    一 概述 JavaScript 语言采用的是单线程模型 也就是说 所有任务只能在一个线程上完成 一次只能做一件事 前面的任务没做完 后面的任务只能等着 随着电脑计算能力的增强 尤其是多核 CPU 的出现 单线程带来很大的不便 无法充分发挥计
  • DBaaS体系及特性

    用户对云计算的交付能力已经不再满足于单纯的基础设施 IaaS 交付 他们希望数据中心中的更多传统IT 服务能以云服务模式进行交付 其中最为迫切的就是数据库 将数据库以云服务模式交付给用户 就是数据库即服务 DBaaS 也称云数据库 传统数据
  • VirusTotal——您身边的企业安全专家

    本文由 Cloud Ace 整理发布 Cloud Ace 是谷歌云全球战略合作伙伴 拥有 300 多名工程师 也是谷歌最高级别合作伙伴 多次获得 Google Cloud 合作伙伴奖 作为谷歌托管服务商 我们提供谷歌云 谷歌地图 谷歌办公套
  • 基于linux环境下安装jre + eclipse cdt

    博客的排版真的好糟糕 请看点击打开链接 一 下载所用到的软件安装包 1 java运行环境 jre 8u112 linux x64 tar gz 2 elipse cdt版本 eclipse cpp neon 2 linux gtk x86
  • pyahocorasick和pyltp包安装方法

    1 安装pyahocorasick 包 pip install pyahocorasick i Simple Index 这个需要VS环境 如果命令行安装提示没有VS环境可以进入 用VS命令行执行pip命令 即可安装成功 2 安装pyltp
  • Vue中el-dialog的用法

    写入HTML
  • 57 openEuler搭建Mariadb数据库服务器-管理数据库用户

    文章目录 57 openEuler搭建Mariadb数据库服务器 管理数据库用户 57 1 创建用户 57 2 查看用户 57 3 修改用户 57 3 1 修改用户名 57 3 2 修改用户示例 57 3 3 修改用户密码 57 3 4 修
  • 关于javaSE8之后的默认方法的整理

    网络中的说法 关于java8接口中默认方法的使用 8在接口中引入了默认方法 通过在方法前加上default关键字就可以在接口中写方法的默认实现 有点类似于C 中的多继承 但是当多个接口或父类中有相同签名的方法时 会引发一些问题 经过实验得出
  • 射频电路学习之滤波电路

    文章目录 前言 一 滤波电路的分类 二 滤波电路的主要参数 1 插入损耗 IL 2 波纹系数 3 频带宽度 4 矩形系数 5 阻带抑制 三 滤波电路设计 1 集总参数滤波电路 巴特沃斯滤波电路 切比雪夫滤波电路 归一化滤波电路的变换 电路变
  • Topaz Video AI for mac(视频增强和修复工具)

    Topaz Video AI for Mac是一款视频增强和修复工具 采用了人工智能技术 可以提高视频的清晰度 降噪 去抖动和插帧等 这款软件支持多种视频格式 包括MP4 MOV AVI等 使用Topaz Video AI for Mac
  • Python基础—面向对象(超详版)

    Python基础 面向对象 面向对象简介 什么是面向对象 类与对象 父类与子类 面向对象的特性 单继承与多继承 单继承 多继承 多层继承 封装 多态 重写与调用 python重写 python调用 super函数 前言 个人主页 以山河作礼
  • VS 使用System.Console打印时输出窗口不显示

    在项目属性中勾选 启用visual studio承载进程 可以在输出窗口中的调试打印信息中显示System Console打印信息
  • 安装PYG

    目录 1 通过Anaconda安装 2 通过pip安装 3 尝试历程 参考 1 通过Anaconda安装 conda install pyg c pyg c conda forge 2 通过pip安装 首先通过如下命令获取系统torch和C
  • Python并行处理数据多进程/多线程,榨干你的CPU

    前言 最近在公司实习 给整了个活 像是数学建模一样的数据分析的活 目标是在几个互相有关联的大表中找出满足某条件的那些业务 其中第一步就是把两个表拼起来 就叫它们A和B吧 省略拼表过程中需要的逻辑判断 串行 两个长为M和N的表 在判断中需要一
  • Oracle删除重复数据只保留一条

    问题描述 merge数据时 找不到唯一的源数据 需要先删除有重复的数据 只保留一条 解决方式 查找表中多余的重复记录 多个字段 select from tmp a where a 料号 a 分类码 in select 料号 分类码 from
  • FFmpeg安装与使用+Java API/SpringBoot项目使用

    目录 下载安装 介绍与简单使用 在项目中的使用 配置文件 工具类 使用 下载安装 Download FFmpeg 解压到指定文件夹 介绍与简单使用 FFmpeg是一个开源的跨平台视频和音频处理工具 可以处理各种格式的音视频文件 FFmpeg
  • echarts实现人物树形关系图实例

    写这个栗子的时候主要因为是刚刚做一个项目 要用到人物关系图 所以一直在找合适插件 最后选择echarts2 0的tree图最合适这个关系图了 哈哈 话不多少 现在就把效果图献上吧 ps 照片是网上下载的 莫要见外啊 这个使用的是echart
  • 引入并使用Element

    引入并使用Element 开发工具与关键技术 MVC 作者 汤池 撰写时间 2022 4 7 1 首先需要打开DW软件 新建一个html网页 然后保存到一个文件夹当中 2 然后打开element官网 下载使用Element必须引用的脚本文件
  • 2022/1/22记录网页

    65条消息 102 bert词向量进行文本分类和命名实体识别 u012416045的博客 CSDN博客 bert文本识别https blog csdn net u012416045 article details 88373965 Bert
  • 记一次kafka无法生产发送消息排查经历

    参考 欢迎点击原文 https stackoverflow com questions 37902167 kafka error while fetching metadata with correlation id leader not