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

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

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

收起
参与9

查看其它 1 个回答lxcorange的回答

lxcorangelxcorange软件架构设计师某券商

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

互联网服务 · 2018-10-19
浏览3112

回答者

lxcorange
软件架构设计师某券商
擅长领域: 大数据数据库数据仓库

lxcorange 最近回答过的问题

回答状态

  • 发布时间:2018-10-19
  • 关注会员:2 人
  • 回答浏览:3112
  • X社区推广