深入理解KAFKA_ADVERTISED_LISTENERS

这篇具有很好参考价值的文章主要介绍了深入理解KAFKA_ADVERTISED_LISTENERS。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、直入主题,解释

(1)第一句话=========

KAFKA_LISTENERS:负责绑定网卡

KAFKA_ADVERTISED_LISTENERS:负责发布外网地址,这个地址会发布到zookeeper中。

(2)第二句话========

内网部署的程序,读的地址是KAFKA_LISTENERS写的。

外网部署的程序,读的地址是KAFKA_ADVERTISED_LISTENERS

zookeeper中存的地址是KAFKA_ADVERTISED_LISTENERS配置的,多个kafka注册到zookeeper就是把这个地址放到zookeeper中。如果不能理解的,可以用客户端工具打开zookeeper,看一下就清楚了。

仔细回味上面这几句话,接下来看实际例子。

(1)内网访问

第一步:kafka配置0.0.0.0:9092,表示内网所有网卡都绑定9092

kafka_advertised_listeners,kafka,kafka,java,spring boot

第二步:程序里写的地址就是内网的地址,下图是,172.16.3.130

KAFKA_CFG_LISTENERS=PLAINTEXT://0.0.0.0:9092

将kafka绑定到局域网所有网卡,当局域网的机器访问的时候,直接在springboot中配置本地ip。如

kafka_advertised_listeners,kafka,kafka,java,spring boot

(2)外网访问

以上程序,如果部署在外网。则需要做如下改变

第一步:KAFKA_CFG_ADVERTISED_LISTENERS配置这个。

KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://<互联网ip>:9092

,这句话意思是将PLAINTEXT://<互联网ip>:9092,放到zookeeper中。当外面的服务访问到zookeeper的时候,从这个地址拿到kafka的内容,看下图,zookeeper中的broker-ids里存的就是这个你写上去的地址。

kafka_advertised_listeners,kafka,kafka,java,spring boot

第二步:springboot程序通过外网访问的时候,配置 改成这样

kafka_advertised_listeners,kafka,kafka,java,spring boot

二、解析原理

kafka_advertised_listeners,kafka,kafka,java,spring boot

(1)程序首先是从zookeeper中获取broker地址。然后用这个地址去连kafka。如果配置的地址是外网程序找不到的一个地址,那就连不上了。

(2)zookeeper中的地址是通过

KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://<互联网ip>:9092

这个关键句来配置的。文章来源地址https://www.toymoban.com/news/detail-783610.html

到了这里,关于深入理解KAFKA_ADVERTISED_LISTENERS的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【深入理解Kafka系列】 第二章 生产者

          生产者就是负责向Kafka发送消息的应用程序。Kafka一共两个大版本的客户端,第一个是开源之处使用Scala编写的客户端;第二个是0.9.x版本开始推出的java编写的客户端。 一个正常的生产逻辑需要以下几个步骤: (1)配置生产者客户端参数及创建相应的生产者实例。 (

    2023年04月26日
    浏览(38)
  • Kafka系列之:深入理解死信队列和重试队列

    由于某些原因消息无法被正确地投递,为了确保消息不会被无故地丢弃,一般将其置于一个特殊角色的队列,这个队列一般称为私信队列。 后续分析程序可以通过消费这个死信队列中的内容来分析当时遇到的异常情况,进而可以改善和优化系统。 与死信队列对应的还有一个

    2023年04月10日
    浏览(52)
  • [AIGC ~ coze] Kafka 消费者——从源码角度深入理解

    一、引言 Kafka 是一个分布式的流处理平台,广泛应用于大规模数据处理和实时数据管道。在 Kafka 生态系统中,消费者扮演着至关重要的角色,它们从 Kafka 主题中读取数据并进行处理。本文将深入探讨 Kafka 消费者的工作原理,包括消费者的基本概念、消费者组、订阅主题、偏

    2024年02月21日
    浏览(41)
  • 深入理解Kafka3.6.0的核心概念,搭建与使用

    Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性就是可以实时的处理大量数据以满足各种需求场景:比如基于hadoop的批处理系统、低延迟的实时系统、Storm/Spark流式处理引擎,we

    2024年02月04日
    浏览(39)
  • 深入理解Spring Kafka中@KafkaListener注解的参数与使用方式

    Apache Kafka作为一个强大的消息代理系统,与Spring框架的集成使得在分布式应用中处理消息变得更加简单和灵活。Spring Kafka提供了 @KafkaListener 注解,为开发者提供了一种声明式的方式来定义消息监听器。在本文中,我们将深入探讨 @KafkaListener 注解的各种参数以及它们的使用方

    2024年01月16日
    浏览(52)
  • Kafka原理、部署与实践——深入理解Kafka的工作原理和使用场景,全面介绍Kafka在实际生产环境中的部署

    作者:禅与计算机程序设计艺术 随着互联网的发展,网站的流量呈爆炸性增长,传统的基于关系型数据库的数据处理无法快速响应。而NoSQL技术如HBase、MongoDB等被广泛应用于分布式数据存储与处理,却没有提供像关系型数据库一样的ACID特性、JOIN操作及完整性约束。因此,很

    2024年02月09日
    浏览(64)
  • 【linux深入剖析】深入理解基础外设--磁盘以及理解文件系统

    🍁你好,我是 RO-BERRY 📗 致力于C、C++、数据结构、TCP/IP、数据库等等一系列知识 🎄感谢你的陪伴与支持 ,故事既有了开头,就要画上一个完美的句号,让我们一起加油 我们所有的文件都是与进程相关的文件–进程打开的文件 系统中是不是所有的文件都被打开了呢?如果没

    2024年04月11日
    浏览(46)
  • 【云原生-深入理解 Kubernetes 系列 3】深入理解容器进程的文件系统

    【云原生-深入理解Kubernetes-1】容器的本质是进程 【云原生-深入理解Kubernetes-2】容器 Linux Cgroups 限制 大家好,我是秋意零。 😈 CSDN作者主页 😎 博客主页 👿 简介 👻 普通本科生在读 在校期间参与众多计算机相关比赛,如:🌟 “省赛”、“国赛” ,斩获多项奖项荣誉证书

    2024年02月06日
    浏览(50)
  • Kafka - 深入了解Kafka基础架构:Kafka的基本概念

    我们首先了解一些Kafka的基本概念。 1)Producer :消息生产者,就是向kafka broker发消息的客户端 2)Consumer :消息消费者,向kafka broker获取消息的客户端 3)Consumer Group (CG):消费者组,由多个consumer组成。消费者组内每个消费者负责消费不同分区的数据,一个broker可以有多个

    2024年02月08日
    浏览(38)
  • kafka原理&架构深入

    https://www.cnblogs.com/zhangzhonghui/articles/12444070.html kafka配置详解 若kafka运行在内网服务器允许外网访问,例如内网ip: 172.10.22.134,外网ip: 9.70.168.130 进行如下配置: 外网访问时使用 9.70.168.130:9092 访问即可 cd kafka安装目录 后台启动 停止 topic producer 查看 consumer-groups 开启consumer消费某

    2024年02月11日
    浏览(79)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包