在线客服
扫描二维码
下载博学谷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架构师的学习路线
相关推荐 更多
Activiti五大特点，你都知道吗？
Activiti是一个开源的工作流引擎，它实现了BPMN 2.0规范，可以发布设计好的流程定义，并通过api进行流程调度。本文主要是以Activiti的特点角度去带大家认识什么是Activiti，给大家一个引导和认识。
11414
2019-07-23 10:18:40
架构和框架的区别是什么？对比分析
架构和框架的区别是什么？相信问这个问题的一定是新手小白。确实会有人在刚刚入门编程的时候，架构和框架的傻傻分不清。本文就框架和架构的定义、使用、特点等等方面，进行对比分析。
15346
2019-08-14 10:19:24
MySQL学习总结之DQL查询语句
DQL查询语句又叫数据库查询语句，这是Java学习者在学习MySQL时，必须了解和掌握的知识点之一。众所周知，DQL查询语句有四种查询方式：排序查询、聚合函数、分组查询和分页查询。下面让我们一一仔细梳理这四种查询方式，有需要学习的小伙伴赶紧来看看MySQL学习总结之DQL查询语句的知识点吧！
5260
2020-02-11 23:24:05
Docker容器引擎实现原理及其应用
Docker是一个开放源代码软件项目能让应用程序布署在软件容器下的工作可以自动化进行。Docker建议单个容器只运行一个应用程序或进程，形成了一个分布式的应用程序模型，在这种模型下应用程序或者服务都可以表示为一系列内部互联的容器，从而使分布式部署应用程序，扩展或调试应用程序都变得比较简单，同时也提高了程序的内省性。
5754
2021-04-26 11:27:08
Redis数据库执行命令速度快的原因是什么？
Redis数据库执行命令速度快的原因是什么？作为服务端工程师工作中Redis用到的比较多。很多人知道Redis 快仅仅因为它是基于内存实现的，对于其它原因倒是模棱两可。
5478
2021-05-11 11:07:52
