V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
guyeuro
V2EX  ›  问与答

kafka 发布的消息只能到一个 partition 吗?

  •  
  •   guyeuro · 2017-08-07 11:26:09 +08:00 · 3527 次点击
    这是一个创建于 2425 天前的主题,其中的信息可能已经有所发展或是发生改变。

    kafka 发送一个消息只能到一个 partition 吗

    这意思只能被一个消费者消费?

    3 条回复    2017-08-09 09:54:31 +08:00
    triffic
        1
    triffic  
       2017-08-07 11:41:52 +08:00
    第一个问题:是的,但这个 partition 会在多台 server 上 replication ;
    第二个问题:不是,
    http://kafka.apache.org/0110/images/consumer-groups.png
    如果消费者在同一个消费者 group,那么这个消息只会被消费者组中的某一个消费者消费;
    如果消费者不在同一个消费者 group,同时又都订阅了这个 topic,那么这个消息会被多个消费者组中的消费者消费。
    所以「消息只能被一个消费者消费」不准确。

    参考![Kafka]<http://kafka.apache.org/intro>
    guyeuro
        2
    guyeuro  
    OP
       2017-08-08 13:21:26 +08:00
    @triffic

    topic 下的一个分区只能被同一个 consumer group 下的一个 consumer 线程来消费
    假如某 topic 分到了 A,B,C 三个分区
    那么订阅了这个 topic 的一个 consumer group 下的一个 consumer 可以同时从这三个分区上消费这个 topic 的消息吗?
    triffic
        3
    triffic  
       2017-08-09 09:54:31 +08:00
    @guyeuro 可以的
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   1488 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 25ms · UTC 17:19 · PVG 01:19 · LAX 10:19 · JFK 13:19
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.