在线客服
扫描二维码
下载博学谷APP
扫描二维码
关注博学谷微信公众号
Kafka消息的分发流程是什么？使用kafka向指定Topic发送消息时，如果该Topic具有多个partition，无论消费者有多少，最终都会保证一个partition内的消息只会被一个Consumer group中的一个Consumer消费，也就是说同一Consumer group中的多个Consumer自动会起到负载均衡的效果。
Kafka消息的分发介绍：
• Producer客户端负责消息的分发
• kafka集群中的任何一个broker都可以向producer提供metadata信息,这些metadata中包含”集群中存活的servers列表”、“partitions leader列表”等信息；
• 当producer获取到metadata信息之后, producer将会和Topic下所有partition leader保持socket连接；
• 消息由producer直接通过socket发送到broker，中间不会经过任何”路由层”。事实上，消息被路由到哪个partition上由producer客户端决定，比如可以采用”random””key-hash””轮询”等。
• 如果一个topic中有多个partitions,那么在producer端实现”消息均衡分发”是必要的。
• 在producer端的配置文件中,开发者可以指定partition路由的方式。
• Producer消息发送的应答机制
设置发送数据是否需要服务端的反馈,有三个值0,1,-1
– 0: producer不会等待broker发送ack
– 1: 当leader接收到消息之后发送ack
– -1: 当所有的follower都同步消息成功后发送ack
request.required.acks=0
— 申请免费试学名额 —
在职想转行提升，担心学不会？根据个人情况规划学习路线，闯关式自适应学习模式保证学习效果
讲师一对一辅导，在线答疑解惑，指导就业！
上一篇：
Java互联网架构师就业前景怎么样？待遇好不好？
下一篇：
从普通的程序员到Java架构师的学习路线
相关推荐 更多
Java基础 Jvm如何加载类？如何分配空间？
Java基础 Jvm如何加载类？如何分配空间？指的是将 class 文件的二进制数据读入到运行时数据区（JVM在内存中划分的）中，并在方法区内创建一个 class 对象JVM 运行起来时就给内存划分空间，这块空间就称为运行时数据区。
8145
2019-06-03 15:41:22
Static局部变量与全局变量的区别？编译后映射文件是否包含此类变量的地址？
全局变量(外部变量)的说明之前再冠以static 就构成了静 态的全局变量。全局变量本身就是静态存储方式， 静态全局变量当然也是静态存储方式。这两者在存储方式上并无不同。这两者的区别虽在于非静态全局变量的作用域是整 个源程序， 当一个源程序由多个源文件组成时，非静态的 全局变量在各个源文件中都是有效的。
13646
2019-06-04 11:57:17
Java基础语法之if语句学习笔记
众所周知，流程控制语句可以分为三类，分别是顺序结构、分支结构和循环结构，而分支结构又可以分为if语句和switch语句。顺序结构可以说是程序中最简单最基本的流程控制，这里就不展开详细讲解了。本文重点要讲解分析的是分支结构的if语句，内容包括了if语句的格式、执行流程和具体示例。想要学习Java基础语法的小伙伴，可以看看下面整理的if语句的笔记，希望对大家入门Java能够有所帮助。
7206
2019-12-06 12:40:32
好用的jQuery瀑布流插件有哪些？
目前有Jquery响应式瀑布流布局插件、23行Jquery代码实现定位瀑布流布局特效、Jquery实现超酷时间轴特效、Aui-core实现模拟MVC单列表绝对定位版瀑布流js特效、Timeline时间轴Jquery特效等。
6083
2019-12-30 16:19:13
30条实用MySQL优化法则
30条实用MySQL优化法则, 应尽量避免在 where 子句中使用!=或<>操作符，否则引擎将放弃使用索引而进行全表扫描。对查询进行优化，应尽量避免全表扫描，首先应考虑在 where 及 order by 涉及的列上建立索引。
2840
2022-06-30 10:53:44
