当前位置: 首页 > news >正文

本地 PC 使用Offset Explorer连接实体Ubuntu Kafka 【单机】超时问题解决

现状:本地 PC 使用Offset Explorer连接实体Ubuntu Kafka 超时

在这里插入图片描述

一、确认kafka是否在9092端口上运行

netstat -tulnp | grep 9092

输出

tcp6       0      0 :::9092                 :::*                    LISTEN      66113/java 

使用jps查看进程66113的详细信息

jps -l | grep 66113

输出如下,可知kafka正在运行中

66113 kafka.Kafka

二、确认ubuntu的9092端口是否放行

sudo ufw status
9092/tcp (v6)              ALLOW       Anywhere (v6)

若返回结果中存在9092且标识为ALLOW则表示为放行,否则执行如下指令

sudo ufw allow 9092/tcp
sudo ufw enable

三、确保kafka配置是否允许对外访问

3-1、ZooKeeper模式

打开kafka安装目录config下的server.properties

root@Pine-Tree:/opt/kafka_2.12-3.9.0/config# nano server.properties

可见listenersadvertised.listeners没有正确配置
在这里插入图片描述
调整如下,保存后退出

 34 listeners=PLAINTEXT://0.0.0.0:90923536 # Listener name, hostname and port the broker will advertise to clients.37 # If not set, it uses the value for "listeners".38 advertised.listeners=PLAINTEXT://192.168.125.102:9092

关闭并重启kafka

bin/kafka-server-stop.sh
bin/kafka-server-start.sh -daemon config/server.properties

3-2、KRafa模式

打开kafka安装目录config/kraft下的server.properties

root@Pine-Tree:/opt/kafka_2.12-3.9.0# nano config/kraft/server.properties 

调整如下,保存后退出

 42 listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:90934344 # Name of listener used for communication between brokers.45 inter.broker.listener.name=PLAINTEXT4647 # Listener name, hostname and port the broker or the controller will advertise to clients.48 # If not set, it uses the value for "listeners".49 advertised.listeners=PLAINTEXT://192.168.125.102:9092,CONTROLLER://192.168.125.102:9093

关闭并重启kafka

bin/kafka-server-stop.sh
bin/kafka-server-start.sh -daemon config/kraft/server.properties

注意事项

ZooKeeper模式和KRafa模式启动时指定的server.properties不同

四、测试验证

成功连接

在这里插入图片描述

http://www.dtcms.com/a/192960.html

相关文章:

  • 印度Rummy游戏支付通道申请策略:技巧类游戏的合规与创新
  • 5.19 BGP实验
  • 动态规划之数列
  • 免疫浸润分析
  • C语言-8.数组
  • Java大师成长计划之第23天:Spring生态与微服务架构之服务发现与注册中心
  • Manus AI 原理深度解析第三篇:Tools
  • 电总协议调试助手更新-PowerBus-v1.0.5
  • 作业帮Java后台开发面试题及参考答案(下)
  • ACI Fabric 中的各种地址
  • OneNote内容太多插入标记卡死的解决办法
  • 汽配知识(三)|跨境电商平台的汽配类目划分与关键词逻辑
  • Hive PredicatePushDown 谓词下推规则的计算逻辑
  • 嵌入式学习笔记DAY21(双向链表、Makefile)
  • 盲盒:拆开未知的惊喜,收藏生活的仪式感
  • 养生:解锁健康生活的核心密码
  • js在浏览器执行原理
  • golang -- 认识channel底层结构
  • AI软件汇总与功能解析:赋能未来的智能工具库
  • 以项目的方式学QT开发(二)——超详细讲解(120000多字详细讲解,涵盖qt大量知识)逐步更新!
  • mysql 基础复习-安装部署、增删改查 、视图、触发器、存储过程、索引、备份恢复迁移、分库分表
  • 8、SpringBoot集成MinIO
  • 鸿蒙OSUniApp 制作简洁高效的标签云组件#三方框架 #Uniapp
  • 插槽(Slot)的使用方法
  • GPUGeek云平台实战:DeepSeek-R1-70B大语言模型一站式部署
  • 应用BERT-GCN跨模态情绪分析:贸易缓和与金价波动的AI归因
  • buildroot使用外部编译链编译bluez蓝牙工具
  • MySQL-数据库分布式XA事务
  • 连接指定数据库时提示not currently accepting connections
  • Golang基础知识—cond