首页 > 其他分享 >Kafka - 消费者会创建多少个 Socket 连接?

Kafka - 消费者会创建多少个 Socket 连接?

时间:2023-09-27 15:57:11浏览次数:31  
标签:Socket 创建 协调者 broker Kafka 有个 连接

相关知识的wiki

https://www.processon.com/mindmap/5ef999275653bb2925bc8a13

 

问题

 假设有个 Kafka 集群由 2 台 Broker 组成,有个主题有 5 个分区,当一个消费该主题的消费者程序启动时,你认为该程序会创建多少个 Socket 连接?为什么?

答案

整个生命周期里会建立4个连接,进入稳定的消费过程后,同时保持3个连接,以下是详细。

  • 第一类连接:确定协调者和获取集群元数据。 一个,初期的时候建立,当第三类连接建立起来之后,这个连接会被关闭。
  • 第二类连接:连接协调者,令其执行组成员管理操作。 一个
  • 第三类连接:执行实际的消息获取。 两个,分别会跟两台broker机器建立一个连接,总共两个TCP连接,同一个broker机器的不同分区可以复用一个socket。

 

标签:Socket,创建,协调者,broker,Kafka,有个,连接
From: https://www.cnblogs.com/frankcui/p/17732880.html

相关文章

  • Kubernetes创建MysQL
    原文:https://www.cnblogs.com/wenkuna/p/16985512.html创建数据存储PV、PVC这里我们使用nfs作为storageclass,具体yaml文件如下:yaml#创建PVapiVersion:v1kind:PersistentVolumemetadata:name:mysqlspec:storageClassName:manualcapacity:storage:20Gi......
  • socket 编程发送和接收缓存大小匹配问题
    socket编程中有发送、接收缓存的情况:例如服务器向客户端发送:105charserver_buf[BUF_SIZE]={0};123if(strncmp(server_buf,"exit",4)!=0)124{125printf("Servergot:%s\n",server_buf);126//将得到的字符串传给......
  • 如何创建可引导的 macOS Sonoma 安装介质
    2023年9月26日(北京时间27日凌晨)macOSSonoma正式版现已发布。如何创建可引导的macOSSonoma安装介质如何创建可引导的macOS安装器|如何制作macOSUSB启动盘请访问原文链接:https://sysin.org/blog/macos-createinstallmedia/,查看最新版。原创作品,转载请保留出处......
  • 拓扑图 题目要求 实验要求: 1、PC1\PC2\PC3\PC4采用DHCP自动获取IP地址,SW5作为服务
    拓扑图题目要求实验要求:1、PC1\PC2\PC3\PC4采用DHCP自动获取IP地址,SW5作为服务器,SW3和SW4作为中继创建地址池ippoolhuawei1和ippoolhuawei2,租期都为2天2、SW3与SW4做链路聚合,采用LACP模式。SW3作为主交换机,优先级为0抢占延时时间为10秒让G0/0/4接口成为非活跃链路,优先级为65000......
  • UE4 创建UObject类
    什么是UObject类?参考:https://zhuanlan.zhihu.com/p/252431932创建一个UObject类的继承类#pragmaonce#include"CoreMinimal.h"#include"Student.generated.h"/****/UCLASS()classMYGAME1_APIUStudent:publicUObject{GENERATED_BODY()public:......
  • vite_vite.config.js配置代理与websocket代理
    exportdefaultdefineConfig({server:{proxy:{"/proxy":{target:"http://121.10.140.87",//线上服务器IP地址changeOrigin:true,ws:true,rewrite:(p......
  • Hive中创建ETL表进行数据清洗
    问题描述今天看到这么一个问题:看到清洗这两个字,就觉得可高级可高级了!!!所以,就把这个问题的解决方法也看了看,学了学;问题的具体解决方法看到了对ETL的分析(抽取-->过滤-->加载):首先创建一个在原表的结构基础上,新增我们所需数据的字段的表;然后执行insert+select操作;之后就ok了;......
  • Kafka 集群副本数量调整
    Kafka创建时未指定多个副本或者副本数量过少,都可以在后期手动添加,另外如果副本过多也可以减少,当前调整基于Kafka的版本是2.5.1,但是估计2.1~2.5应该都是兼容的。下面先来操作一下Topic副本减少的过程,首先查看KafkaTopic的详情:#新版本的Kafka建议使用--bootstrap......
  • idea创建父子项目
    1.创建大的project父工程 2. 3.4.删除不需要的文件,保留pom文件,检查对应的jar和springbootpartnert版本: 5. 创建子项目(module项目):1、选中父模块,点击鼠标右键,然后点击New—>Module。2、在NewModule界面使用Maven创建,点击Next。3. GroupId 可以默认为父项目......
  • 创建在建安装包
    创建在建安装包新建模板小书匠在线安装包会获取仓库描述(Updates.xml),与存在包中的描述文件进行对比。创那一个库repository,并将其传至web服务器。然后在生成安装包的config.xml中指定升级仓库的路径。创建仓库在package路径中,使用repogen工具为所有的包创建在线仓库:repogen.......