关于Kafka报错 Connection to xxx could not be established. Broker may not be available.

2023-10-28 18:30

本文主要是介绍关于Kafka报错 Connection to xxx could not be established. Broker may not be available.,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.错误如图所示:
前提:standalone模式下(也可以理解是单节点分布式,毕竟我的Kafka也是注册了zookeeper的),启动connector!
在这里插入图片描述
2.错误把脉:
出现以上错误一定是KafkaHost设置错误问题。
查看log,发现大问题:

在这里插入图片描述
震惊!害怕!server地址都不统一!不可能成功的,外部连接不上也是正常的。

3.整体操作:
(1).启动zookeeper
zookeeper-start.sh zookeeper.properties
#其中zookeeper.properties主要注意zookeeper所在服务器HOST;
(2).启动kafka
kafka-server-start.sh server.properties
#其中server.properties主要涉及listener / advertised-listener的设置:
主要是要补充kafka服务启动所在的服务器HOST;
(3).启动connector
connect-standalone.sh connect-standalone.properties mysql-source-test.properties
#其中 connect-standalone.properties种要设置bootstrap.servers=服务器HOST
这是极为重要的,众所周知,在Kafka的连接中,这个是必不可少的参数!
4.补充说明:
(1).对于mysql-source-test.properties主要是对connect外部source的参数指定,最终connect成功的话,生成的topic会是topic-prefix + table.whitelist格式,如果错误,kafka-topics.sh --list --zookeeper localhost:2181出来的会是这个参数文件中的name。
(2).对于出错的进程和topic需要删除:
杀死进程命令:kill -9 进程pid
删除topic需要主意:server.properties 设置 delete.topic.enable=true;
如果没有设置 delete.topic.enable=true,则调用kafka 的delete命令无法真正将topic删除,而是显示(marked for deletion)。

这篇关于关于Kafka报错 Connection to xxx could not be established. Broker may not be available.的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/295129

相关文章

搭建Kafka+zookeeper集群调度

前言 硬件环境 172.18.0.5        kafkazk1        Kafka+zookeeper                Kafka Broker集群 172.18.0.6        kafkazk2        Kafka+zookeeper                Kafka Broker集群 172.18.0.7        kafkazk3

Jenkins 插件 地址证书报错问题解决思路

问题提示摘要: SunCertPathBuilderException: unable to find valid certification path to requested target...... 网上很多的解决方式是更新站点的地址,我这里修改了一个日本的地址(清华镜像也好),其实发现是解决不了上述的报错问题的,其实,最终拉去插件的时候,会提示证书的问题,几经周折找到了其中一遍博文

【Python报错已解决】AttributeError: ‘list‘ object has no attribute ‘text‘

🎬 鸽芷咕:个人主页  🔥 个人专栏: 《C++干货基地》《粉丝福利》 ⛺️生活的理想,就是为了理想的生活! 文章目录 前言一、问题描述1.1 报错示例1.2 报错分析1.3 解决思路 二、解决方法2.1 方法一:检查属性名2.2 步骤二:访问列表元素的属性 三、其他解决方法四、总结 前言 在Python编程中,属性错误(At

DBeaver 连接 MySQL 报错 Public Key Retrieval is not allowed

DBeaver 连接 MySQL 报错 Public Key Retrieval is not allowed 文章目录 DBeaver 连接 MySQL 报错 Public Key Retrieval is not allowed问题解决办法 问题 使用 DBeaver 连接 MySQL 数据库的时候, 一直报错下面的错误 Public Key Retrieval is

Caused by: org.hibernate.MappingException: Could not determine type for: org.cgh.ssh.pojo.GoodsType,

MappingException:这个主要是类映射上的异常,Could not determine type for: org.cgh.ssh.pojo.GoodsType,这句话表示GoodsType这个类没有被映射到

vue 父组件调用子组件的方法报错,“TypeError: Cannot read property ‘subDialogRef‘ of undefined“

vue 父组件调用子组件的方法报错,“TypeError: Cannot read property ‘subDialogRef’ of undefined” 最近用vue做的一个界面,引入了一个子组件,在父组件中调用子组件的方法时,报错提示: [Vue warn]: Error in v-on handler: “TypeError: Cannot read property ‘methods

Java消息队列:RabbitMQ与Kafka的集成与应用

Java消息队列:RabbitMQ与Kafka的集成与应用 大家好,我是微赚淘客返利系统3.0的小编,是个冬天不穿秋裤,天冷也要风度的程序猿! 在现代的分布式系统中,消息队列是实现系统间通信、解耦和提高可扩展性的重要组件。RabbitMQ和Kafka是两个广泛使用的消息队列系统,它们各有特点和优势。本文将介绍如何在Java应用中集成RabbitMQ和Kafka,并展示它们的应用场景。 消息队

Kafka (快速)安装部署

文章目录 1、软件下载&配置环境1_JDK安装2_Zookeeper安装3_Kafka安装 2、单机安装1_配置主机名和IP映射2_单机Kafka配置 3、集群安装1_配置主机名和IP的映射关系2_时钟同步3_Zookeeper配置信息4_集群Kafka配置 4、kafka的其他脚本命令 1、软件下载&配置环境 下面的操作无论是单机部署还是分布式集群环境下都是通用的。 准

Vue3上传图片报错:Current request is not a multipart request

当你看到错误 "Current request is not a multipart request" 时,这通常意味着你的服务器或后端代码期望接收一个 multipart/form-data 类型的请求,但实际上并没有收到这样的请求。在使用 <el-upload> 组件时,如果你已经设置了 http-request 属性来自定义上传行为,并且遇到了这个错误,可能是因为你在发送请求时没有正确地设置

QT 编译报错:C3861: ‘tr‘ identifier not found

问题: QT 编译报错:C3861: ‘tr’ identifier not found 原因 使用tr的地方所在的类没有继承自 QObject 类 或者在不在某一类中, 解决方案 就直接用类名引用 :QObject::tr( )