使用kafka传输消息时,如何能确保consumer接受到的消息顺序与消息发送方保持一致?

在kafka中,Topic在逻辑上可以被认为是一个在的queue,每条消费都必须指定它的topic,可以简单理解为必须指明把这条消息放进哪个queue里。 为了使得Kafka的吞吐率可以水平扩展,物理上把topic分成一个或多个partition,如何能确保consumer接受到的消息顺序与消息发送方保持一致

2回答

windixwindix  商业智能工程师 , 蚂蚁金服
ckn126yinxinaixchina赞同了此回答
Kafka可保证在同一partition中的消息是有序的,producer把数据按照同一主键发到同一个partition即可。显示全部

Kafka可保证在同一partition中的消息是有序的,producer把数据按照同一主键发到同一个partition即可。

收起
 2018-10-19
浏览1740
aixchina 邀答
lxcorangelxcorange  软件架构设计师 , 某券商
aixchina王希瑞赞同了此回答
如果需要确保consumer接受到的消息顺序与消息发送方保持一致,比如增删改等有顺序要求的操作,只能在topic中设置唯一一个partition,所有消息都使用同一个partition发送和接受。显示全部

如果需要确保consumer接受到的消息顺序与消息发送方保持一致,比如增删改等有顺序要求的操作,只能在topic中设置唯一一个partition,所有消息都使用同一个partition发送和接受。

收起
 2018-10-19
浏览1651

提问者

lxcorange软件架构设计师, 某券商

问题状态

  • 发布时间:2018-10-18
  • 关注会员:2 人
  • 问题浏览:2615
  • 最近回答:2018-10-19