guyeuro
V2EX  ›  问与答

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

  •  
  •   guyeuro · Aug 7, 2017 · 4424 views
    This topic created in 3265 days ago, the information mentioned may be changed or developed.

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

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

    3 replies    2017-08-09 09:54:31 +08:00
    triffic
        1
    triffic  
       Aug 7, 2017
    第一个问题:是的,但这个 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
       Aug 8, 2017
    @triffic

    topic 下的一个分区只能被同一个 consumer group 下的一个 consumer 线程来消费
    假如某 topic 分到了 A,B,C 三个分区
    那么订阅了这个 topic 的一个 consumer group 下的一个 consumer 可以同时从这三个分区上消费这个 topic 的消息吗?
    triffic
        3
    triffic  
       Aug 9, 2017
    @guyeuro 可以的
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   3136 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 30ms · UTC 14:10 · PVG 22:10 · LAX 07:10 · JFK 10:10
    ♥ Do have faith in what you're doing.