2019-07-17

dx   近几日,因为公司业务需求的原因,自己又开始转行玩起了java开发工作,配合F&B系统的数据模块的开发工作。 在经过了大量的咨询查阅之后,确定了自己这块本身的项目架构。理解了很多的架构逻辑,知道了多种解决业务问题的具体思路,在最后通过leader,leeYond的领导下,成功的确定了架构的搭建思路与方向。 最后使用kafka这个消息中间组件,来完成整个模块的信息交流问题。 可是在kafka的学习中,自己又遇到了个问题,在确认kafka启动无异常的情况下,producer,可以"正常"的sent数据,而 consumer 无法读出数据。

解决思路:

     排查问题: 首先查阅kafka日志,判定系统是否正常的 接收到了 producer sent的数据。 

    经排查,kafka并未正常接收到数据,而 kafka的sent 返回参数,又是一个Future 对象,随意查阅起来很是麻烦,自己为了节省代码量,就没写这部分,所以只是打印了发送结束的日志,而真正的报错日志就这样子忽略了过去。 

开启spring boot的 的日志 debug 模式,查看详细日志. 经判定,原本部署在公司内网 38 服务器上的6667 端口的kafka,理论上的connect的 192.168.1.38:6667  ,却被解析成了 dxg-ml:6667,而 dxg-ml 是kafka的别名,为啥会被系统默认为连接呢。

自己配置的明明是ip,程序内部却去获取他的别名,那如果生产者所在机器上没有配置这个ip的别名,就不能解析到对应的ip,所以连接失败报错。


最后,解决思路,就是去配置 自己本地电脑的路径指向:

 windows:

C:\Windows\System32\drivers\etc\hosts  

 添加  192.168.1.38   dxg-ml  

linux :

vi /etc/hosts

  添加 192.168.1.38  dxg-ml

问题得以解决。   具体原因尚不明确,可能是kafka的问题。

博客原文:https://blog.csdn.net/maoyuanming0806/article/details/80553632

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • day14阶段知识总结 第四个阶段-系统基础命令操作 vi命令将光标移动到文件最后一行 大小字母G...
    ManBu_x阅读 349评论 0 0
  • 背景: 家里用的是电信的宽带。后来参加联通的存话费送手机活动同时送了一条宽带,所以平时以电信宽带为主,联通宽带备用...
    衣明_lpsssz阅读 1,959评论 0 50
  • What is ai?It is the future.And! It will define what we a...
    cjs2019阅读 1,630评论 0 0
  • 写作专题:这些年 我走过的城市 专题介绍:回望这几年下来我竟然跑了十来个国家N个城市,从一开始的景点和穷游,到现在...
    lovinzh阅读 173评论 0 1
  • 嗒,嗒,嗒……清晰的脚步声缓缓而来,我沉睡千年,还未有人发现过。未睁眼,脚步声就停下了,轻轻抚摸了我的头。然后,嗒...
    会会君阅读 2,566评论 3 38

友情链接更多精彩内容