简答题
kafka 分布式(不是单机)的情况下,如何保证消息的顺序消费?
答案解析
正确答案:Kafka 中发送 1 条消息的时候,可以指定(topic, partition, key) 3 个参数,partiton 和 key 是可选的。
Kafka 分布式的单位是 partition,同一个 partition 用一个 write ahead log 组织,所以可以保证FIFO 的顺序。
不同 partition 之间不能保证顺序。因此你可以指定 partition,将相应的消息发往同 1个 partition,并且在消费端,Kafka 保证1 个 partition 只能被1 个 consumer 消费,就可以实现这些消息的顺序消费。
另外,你也可以指定 key(比如 order id),具有同 1 个 key 的所有消息,会发往同 1 个partition,那这样也实现了消息的顺序消息。
Kafka 分布式的单位是 partition,同一个 partition 用一个 write ahead log 组织,所以可以保证FIFO 的顺序。
不同 partition 之间不能保证顺序。因此你可以指定 partition,将相应的消息发往同 1个 partition,并且在消费端,Kafka 保证1 个 partition 只能被1 个 consumer 消费,就可以实现这些消息的顺序消费。
另外,你也可以指定 key(比如 order id),具有同 1 个 key 的所有消息,会发往同 1 个partition,那这样也实现了消息的顺序消息。
相关题目
单选题
一号双终端业务附卡不能办理的业务是()
单选题
依托数字沙盘大屏、数据看板中屏、()小屏,打造市场数字化洞察、平台数字化拓展、一线数字化营销三大能力,三屏联动,场景化赋能网络补强、渠道补盲、平台渗透及业务运营,全面盘活农村市场拓展能力
单选题
数字乡村服务云平台通过PC端进行移动门户配置,实现一次配置,多端同时生效,并提供统一的登录界面。以下不属于生效端的是()
单选题
以下哪项工作内容不是由2022年3月18日中国联通党组印发的36号文《中国联通2022年助力乡村振兴工作要点》所要求()
单选题
资源不充分地区,可参照陕西、四川、湖南等省()模式,营装维一体化运营,将有实力的BOT服务商建设培养为综合业务代理商
单选题
2022年,双优乡镇应至少建设()个实体店,5万人乡镇至少建设()个实体店
单选题
下列不属于网络补强、渠道补盲场景的应用模型为()
单选题
实现全量客户、增量客户、双优乡镇上图,可以透视()
单选题
2022年数字乡村BU数字乡村平台村民激活率目标为(),村民活跃量计划达到()万
单选题
农村市场总体经营思路年度目标中,双优乡镇渠道覆盖率由88%提升到
