脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → kafka内外网访问配置

kafka内外网访问配置方式

 更新时间：2023年09月16日 09:15:28   作者：飘然渡沧海  
这篇文章主要介绍了kafka内外网访问配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

kafka

kafka里面两种监听配置

内网监听配置

listeners=PLAINTEXT://192.168.0.213:9092

配置完内网可以正常得去消费或者添加kfka数据

如果配置了 advertised.listeners 就无法正常访问消费

advertised.listeners=PLAINTEXT://101.89.163.1:9092

WARN [Consumer clientId=consumer-console-consumer-94880-1, groupId=console-consumer-94880] Error while fetching metadata with correlation id 2 : {ooxx=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

因为我的外网通讯虽然注册得zookeeper里面了，但是外网网络无法在kafka 集群机器上来回通讯导致问题，所以这个时候需要切换成内外网分流访问

内外网分流

方法1

listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://192.168.0.213:19092
advertised.listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
inter.broker.listener.name=INTERNAL

方法2

listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
advertised.listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
inter.broker.listener.name=INTERNAL

注意这两的区别是listeners的EXTERNAL使用的ip不一样，一个使用内网ip，一个使用外网ip。

  • 如果你的kafka宿主机有外网网卡，只能用外网ip，若使用配置1，kafka通过listeners监听的两个端口都是内网网卡的数据，无法接收到外网网卡数据；
  • 如果你的kafka宿主机外网ip是映射来的，只能使用内网ip，原因也是上面说过的，不存在外网网卡，kafka启动监听就会报错，而使用内网ip有环境配置好的转发，可以接收到外网ip的数据。

在这里配置得 kafka内部访问端口与外部访问端口不能是一致得。

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Java多线程编程之Lock用法实例

    Java多线程编程之Lock用法实例

    这篇文章主要介绍了Java多线程编程之Lock用法实例,本文直接给出代码实例,需要的朋友可以参考下
    2015-05-05
  • PowerJob的DatabaseMonitorAspect源码流程

    PowerJob的DatabaseMonitorAspect源码流程

    这篇文章主要为大家介绍了PowerJob的DatabaseMonitorAspect源码流程解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2024-01-01
  • hibernate 中 fetch=FetchType.LAZY 懒加载失败处理方法

    hibernate 中 fetch=FetchType.LAZY 懒加载失败处理方法

    这篇文章主要介绍了hibernate 中 fetch=FetchType.LAZY 懒加载失败处理方法,需要的朋友可以参考下
    2017-09-09
  • mybatis插入数据后返回自增主键ID的两种实现方式

    mybatis插入数据后返回自增主键ID的两种实现方式

    这篇文章主要介绍了mybatis插入数据后返回自增主键ID的两种实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • java中Object类4种方法详细介绍

    java中Object类4种方法详细介绍

    大家好，本篇文章主要讲的是java中Object类4种方法详细介绍，感兴趣的同学赶快来看一看吧，对你有帮助的话记得收藏一下，方便下次浏览
    2022-01-01
  • java注解@Override用法举例详解

    java注解@Override用法举例详解

    这篇文章主要介绍了java注解@Override用法的相关资料,@Override 是Java中的一个注解,用于表明一个方法重写了父类或接口中的方法,它可以帮助编译器检查方法签名是否正确,避免拼写错误或参数列表不一致导致的低级错误,需要的朋友可以参考下
    2024-12-12
  • 详解java动态代理模式

    详解java动态代理模式

    这篇文章主要为大家详细介绍了java动态代理模式，总结一下代理模式，以及jdk,cglib代理模式用法，来理解代理模式，感兴趣的小伙伴们可以参考一下
    2016-02-02
  • JVM 运行时数据区与JMM 内存模型

    JVM 运行时数据区与JMM 内存模型

    这篇文章主要介绍了JVM 运行时数据区与JMM 内存模型，文章围绕主题展开详细的内容介绍，具有一定的参考价值。需要的朋友可以参考一下
    2022-07-07
  • spring使用xml方式整合Druid数据源连接池

    spring使用xml方式整合Druid数据源连接池

    传统的JDBC数据库连接方式,每次连接都需加载Connection到内存并验证,使用后再放回,从而重复利用数据库连接资源,这不仅降低了系统资源消耗,还避免了频繁连接导致的服务器崩溃和内存泄漏风险,数据库连接池在初始化时创建并保持最小数量的数据库连接
    2024-10-10
  • idea如何自动生成serialVersionUID

    idea如何自动生成serialVersionUID

    这篇文章主要介绍了idea如何自动生成serialVersionUID,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02

最新评论