zoukankan      html  css  js  c++  java
  • kafka 分布式(不是单机)的情况下,如何保证消息的顺序消费?

    Kafka 分布式的单位是 partition,同一个 partition 用一个 write ahead log 组织

    所以可以保证 FIFO 的顺序不同 partition 之间不能保证顺序但是绝大多数用 

    户都可以通过 message key 来定义因为同一个 key  message 可以保证只发 

    送到同一个 partition。

    Kafka 中发送 1 条消息的时候可以指定(topic, partition, key) 3 个参数

    partiton  key 是可选的如果你指定了 partition,那就是所有消息发往同 1

     partition,就是有序的并且在消费端,Kafka 保证,1  partition 只能被 

    1  consumer 消费或者你指定 key(比如 order id),具有同 1  key  

    所有消息会发往同 1  partition。

    Java Program!
  • 相关阅读:
    1104
    HDU 1575
    hdu 1142(DFS+dijkstra)
    hdu 1015(DFS)
    hdu 1342(DFS)
    hdu 1181(DFS)变 形 课
    hdu 1312(DFS)
    hdu 5976 Detachment
    hdu 5795
    UVa 11729
  • 原文地址:https://www.cnblogs.com/programb/p/12995972.html
Copyright © 2011-2022 走看看