在kafka中,Topic在逻辑上可以被认为是一个在的queue,每条消费都必须指定它的topic,可以简单理解为必须指明把这条消息放进哪个queue里。 为了使得Kafka的吞吐率可以水平扩展,物理上把topic分成一个或多个partition,如何能确保consumer接受到的消息顺序与消息发送方保持一致
Kafka可保证在同一partition中的消息是有序的,producer把数据按照同一主键发到同一个partition即可。
如果需要确保consumer接受到的消息顺序与消息发送方保持一致,比如增删改等有顺序要求的操作,只能在topic中设置唯一一个partition,所有消息都使用同一个partition发送和接受。
关于TWT使用指南社区专家合作厂商入驻社区企业招聘投诉建议版权与免责声明联系我们 © 2024talkwithtrend — talk with trend,talk with technologist京ICP备09031017号-30