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

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

参与9

2同行回答

windixwindix联盟成员商业分析师某证券公司
Kafka可保证在同一partition中的消息是有序的,producer把数据按照同一主键发到同一个partition即可。显示全部

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

收起
互联网服务 · 2018-10-19
lxcorangelxcorange软件架构设计师某券商
如果需要确保consumer接受到的消息顺序与消息发送方保持一致,比如增删改等有顺序要求的操作,只能在topic中设置唯一一个partition,所有消息都使用同一个partition发送和接受。显示全部

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

收起
互联网服务 · 2018-10-19
浏览3113

提问者

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

问题来自

相关问题

相关资料

相关文章

问题状态

  • 发布时间:2018-10-18
  • 关注会员:2 人
  • 问题浏览:4502
  • 最近回答:2018-10-19
  • X社区推广