脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → 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内部访问端口与外部访问端口不能是一致得。

总结

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

您可能感兴趣的文章:

相关文章

  • IDEA设置生成带注释的getter和setter的图文教程

    IDEA设置生成带注释的getter和setter的图文教程

    通常我们用idea默认生成的getter和setter方法是不带注释的，当然，我们同样可以设置idea像MyEclipse一样生成带有Javadoc的模板，具体设置方法，大家参考下本文
    2018-05-05
  • 深入理解JSON及其在Java中的应用小结

    深入理解JSON及其在Java中的应用小结

    json它是一种轻量级的数据交换格式,由于其易于阅读和编写,同时也易于机器解析和生成,因此广泛应用于网络数据交换和配置文件,这篇文章主要介绍了深入理解JSON及其在Java中的应用,需要的朋友可以参考下
    2023-12-12
  • MyBatis-Plus中AutoGenerator的使用案例

    MyBatis-Plus中AutoGenerator的使用案例

    AutoGenerator是MyBatis-Plus的代码生成器，通过 AutoGenerator 可以快速生成 Pojo、Mapper、 Mapper XML、Service、Controller 等各个模块的代码，这篇文章主要介绍了MyBatis-Plus中AutoGenerator的详细使用案例,需要的朋友可以参考下
    2023-05-05
  • Java利用完全二叉树创建大根堆和小根堆

    Java利用完全二叉树创建大根堆和小根堆

    大根堆是每个结点的值不大于他的父亲结点的值；小根堆是每个结点的值不小于他的父亲结点的值。本文将利用完全二叉树创建大根堆和小根堆，感兴趣的可以了解一下
    2022-08-08
  • 重新启动IDEA时maven项目SSM框架文件变色所有@注解失效

    重新启动IDEA时maven项目SSM框架文件变色所有@注解失效

    这篇文章主要介绍了重新启动IDEA时maven项目SSM框架文件变色所有@注解失效，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03
  • 详解SpringMVC学习系列（6） 之 数据验证

    详解SpringMVC学习系列（6） 之 数据验证

    这篇文章主要介绍了详解SpringMVC学习系列（6） 之 数据验证 ,具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
    2016-12-12
  • SpringBoot访问web中的静态资源的方式小结

    SpringBoot访问web中的静态资源的方式小结

    这篇文章主要介绍了SpringBoot访问web中的静态资源的方式,本文给大家介绍了两种方式,通过代码示例和图文讲解的非常详细,具有一定的参考价值,需要的朋友可以参考下
    2024-10-10
  • Java多线程中的单例模式两种实现方式

    Java多线程中的单例模式两种实现方式

    这篇文章主要介绍了Java多线程中的单例模式两种实现方式的相关资料,需要的朋友可以参考下
    2017-04-04
  • 四种Springboot常见全局时间格式化方式

    四种Springboot常见全局时间格式化方式

    这篇文章主要为大家详细介绍了Springboot实现全局时间格式化的四种常见方式,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
    2023-12-12
  • spring boot搭建文件服务器解决同时上传多个图片和下载的问题

    spring boot搭建文件服务器解决同时上传多个图片和下载的问题

    这篇文章主要介绍了spring boot搭建文件服务器解决同时上传多个图片和下载的问题,本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下
    2019-11-11

最新评论