Backgroud

最近遇到这样一个情况:基于CDH6.2在国科云上搭建了一套大数据的环境,没有给v-p-n,在内网可以正常访问Kafka集群,但是在window开发环境下无法访问(其实是无法访问9092端口,无法生产和消费数据),通过尝试最终解决问题,如下记录:

修改kafka.properties

kafka.properties中添加下面两行,node01是Kafka节点IP。
但是在CDH环境下,kafka.properties是动态生成的,直接修改配置文件没用,需要在CDH的管理界面修改配置,步骤如下所示

listeners=PLAINTEXT://0.0.0.0:9092,
advertised.listeners=PLAINTEXT://node01:9092
  • 1、打开CDH管理界面,点击Kafka进入Kafka操作详情页面
    在这里插入图片描述

  • 2、然后点击实例,可以看到有五个broker节点
    在这里插入图片描述

  • 3、点击其中的一个broker
    在这里插入图片描述

  • 4、然后点击配置
    在这里插入图片描述

  • 5、然后搜索高级,在kafka.properties中加入上面所说的两行代码
    在这里插入图片描述

  • 6、重复上面步骤,修改所有节点,记得修改IP(我这里做了映射,所以是主机名)

  • 7、重启Kafka服务

  • 8、在Kafka节点执行如下命令,可以看到9092端口的监听地址从原来的本机IP变成了两个冒号(:::9092)或者是四个0(0.0.0.0:9092),这个都代表所有IP地址,一个是IP V6地址,一个是IP V4形式的

[root@sutong01 ~]# netstat -anp | grep 9092
tcp6       0      0 192.168.18.110:9092     :::*                    LISTEN      17189/java
tcp6       0      0 192.168.18.110:55576    192.168.18.160:9092     ESTABLISHED 17189/java
[root@sutong01 ~]# netstat -anp | grep 9092
tcp6       0      0 :::9092     			:::*                    LISTEN      17189/java
tcp6       0      0 192.168.18.110:55576    192.168.18.160:9092     ESTABLISHED 17189/java
Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐