在线客服
扫描二维码
下载博学谷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 12 / JDK 12 正式发布有哪些新特性
Java 12 / JDK 12 正式发布有哪些新特性？具体变化有Shenandoah：低暂停时间的 GC（实验性功能）、Microbenchmark Suite等内容。
10839
2019-08-14 10:32:28
浅析Java并发工具类在AQS实现
众所周知，AQS是一个Java提高的底层同步工具类。本文就AQS的资源共享方式，state的作用，自定义同步器的方法，CountDownLatch，Semaphore，Semaphore和RateLimiter的区别，CyclicBarrier几方面来为大家浅析Java并发工具类。
10099
2019-08-05 20:07:43
Java垃圾回收器相关问题解答
相信很许多人在学习Java的时候，都没有搞清楚过Java垃圾回收器。因此本文主要讲述了Java垃圾回收器的定义、性能评估工具、回收算法等等内容，为大家全面解答垃圾回收器的相关问题。
7644
2019-08-20 15:55:44
学Java编程数学一定要很好吗？
数学好不好对于学Java编程没有特别的限制，编程要一定的逻辑思维能力，数学好说明逻辑思维能力强，对学好编程很有帮助，但对学编程有兴趣，即使数学不好但在学习编程的过程中会促使你去学好数学，两者相互促进。
7245
2020-10-21 14:47:43
微服务和分布式的区别什么？有什么特点？
微服务设计是为了不因为某个模块的升级和BUG影响现有的系统业务。微服务与分布式的细微差别是，微服务的应用不一定是分散在多个服务器上也可以是同一个服务器。分布式属于微服务，将模块拆分成一个独立的服务单元通过接口来实现数据的交互。分布式和微服的架构很相似，只是部署的方式不一样而已。
7082
2021-03-10 11:10:50
