在线客服
扫描二维码
下载博学谷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 运行起来时就给内存划分空间，这块空间就称为运行时数据区。
7717
2019-06-03 15:41:22
JSP四大作用域及请求范围总结
程序员在写代码的时候，难免会遇到作用域的问题，今天我们要谈的也是JSP的四大作用域。本文主要总结了JSP四大作用域page、request、session和application和它们的请求范围。
8792
2019-08-19 17:23:19
MySQL中数据库的设计归纳讲解
谈到MySQL中数据库的设计，相信大家都知道这是实现实际业务的重要一步，因此对于Java学习者来说，深入了解和学习数据库的设计是十分有必要的。本文为大家准备了一份MySQL中数据库的设计归纳讲解，内容包括了多表之间的关系，像是分类、实现以及案例分析，还有数据库设计的范式概念和分类等等。有学习兴趣的朋友现在赶紧接着看下去吧！
4139
2020-02-13 14:53:59
Java基础语法学习之常量与变量
今天Java基础语法学习的内容是常量与变量，顾名思义，常量就是不会发生改变的，而变量则恰好相反。本文主要总结了常量的概念、分类、案例演示，还有变量的概念、格式以及使用。下面就一起梳理下相关得基础知识点吧~
4755
2020-05-14 15:31:15
什么是Java运算？Java运算：比九九乘法表还简单
提到运算，你可能会立即想到加、减、乘、除四则运算以及“九九乘法表”。Java 语言中有很多进行数据运算的方式，比如：算术运算、比较运算、逻辑运算、赋值运算、三目运算等。每一种运算方式，又都包含了很多的运算符，小编把这些运算符形象的称为“十八般武艺”，学习 Java 中的运算，就是学习这些运算符的使用，也就是修炼这“十八般武艺”的过程。
3370
2021-07-15 15:16:23
