关于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

相关文章

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》:本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景:为什么我的接口突然报错了?二、为什么会发生这个错误?1. Java 数据类型的“容量”限制

SpringBoot项目中报错The field screenShot exceeds its maximum permitted size of 1048576 bytes.的问题及解决

《SpringBoot项目中报错ThefieldscreenShotexceedsitsmaximumpermittedsizeof1048576bytes.的问题及解决》这篇文章... 目录项目场景问题描述原因分析解决方案总结项目场景javascript提示:项目相关背景:项目场景:基于Spring

深入理解Apache Kafka(分布式流处理平台)

《深入理解ApacheKafka(分布式流处理平台)》ApacheKafka作为现代分布式系统中的核心中间件,为构建高吞吐量、低延迟的数据管道提供了强大支持,本文将深入探讨Kafka的核心概念、架构... 目录引言一、Apache Kafka概述1.1 什么是Kafka?1.2 Kafka的核心概念二、Ka

解决SpringBoot启动报错:Failed to load property source from location 'classpath:/application.yml'

《解决SpringBoot启动报错:Failedtoloadpropertysourcefromlocationclasspath:/application.yml问题》这篇文章主要介绍... 目录在启动SpringBoot项目时报如下错误原因可能是1.yml中语法错误2.yml文件格式是GBK总结在启动S

idea maven编译报错Java heap space的解决方法

《ideamaven编译报错Javaheapspace的解决方法》这篇文章主要为大家详细介绍了ideamaven编译报错Javaheapspace的相关解决方法,文中的示例代码讲解详细,感兴趣的... 目录1.增加 Maven 编译的堆内存2. 增加 IntelliJ IDEA 的堆内存3. 优化 Mave

如何解决mmcv无法安装或安装之后报错问题

《如何解决mmcv无法安装或安装之后报错问题》:本文主要介绍如何解决mmcv无法安装或安装之后报错问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mmcv无法安装或安装之后报错问题1.当我们运行YOwww.chinasem.cnLO时遇到2.找到下图所示这里3.

浅谈配置MMCV环境,解决报错,版本不匹配问题

《浅谈配置MMCV环境,解决报错,版本不匹配问题》:本文主要介绍浅谈配置MMCV环境,解决报错,版本不匹配问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录配置MMCV环境,解决报错,版本不匹配错误示例正确示例总结配置MMCV环境,解决报错,版本不匹配在col

SpringBoot启动报错的11个高频问题排查与解决终极指南

《SpringBoot启动报错的11个高频问题排查与解决终极指南》这篇文章主要为大家详细介绍了SpringBoot启动报错的11个高频问题的排查与解决,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一... 目录1. 依赖冲突:NoSuchMethodError 的终极解法2. Bean注入失败:No qu

springboot报错Invalid bound statement (not found)的解决

《springboot报错Invalidboundstatement(notfound)的解决》本文主要介绍了springboot报错Invalidboundstatement(not... 目录一. 问题描述二.解决问题三. 添加配置项 四.其他的解决方案4.1 Mapper 接口与 XML 文件不匹配

java常见报错及解决方案总结

《java常见报错及解决方案总结》:本文主要介绍Java编程中常见错误类型及示例,包括语法错误、空指针异常、数组下标越界、类型转换异常、文件未找到异常、除以零异常、非法线程操作异常、方法未定义异常... 目录1. 语法错误 (Syntax Errors)示例 1:解决方案:2. 空指针异常 (NullPoi