蛰伏的庶人

0 声望

这家伙太懒,什么都没留下

个人动态
  • 贬了 蛰伏的庶人kafka中文教程 的评论!

    不是轮流,在正常情况下是固定的。

    跟topic的分区数有关。

    比如,你的topic有3个分区,那么你的3个消费者每人会固定消费其中1个分区的消息。
    如果你的topic有2个分区,那么你其中一个消费者永远也拿不到消息,直到有其他的消费者故障了。

    2年前
  • 半兽人 回复 蛰伏的庶人kafka中文教程 中 :

    查询确认一下就知道了:

    ## 新消费者列表查询
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
    
    ## 显示某个消费组的消费详情(0.10.1.0版本+)
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
    

    来自:kafka命令大全

    ps:有问题可以到问题专区提问。

    2年前
  • 蛰伏的庶人 回复 半兽人kafka中文教程 中 :

    博主我刚刚学习kafka,请教一个问题,kafkaf服务端是两个节点集群部署的,我用idea写了两个消费者客户端程序,这两个消费者属于同一个消费组,而且订阅的是同一个主题mytopic(两个分区),我在服务端通过produce的shell命令在该主题下投递了一条消息,为什么我idea两个消费端都收到了消息呢?我看官网文档说主题的每个分区,消费组中只有其中一个消费者来消费消息,为什么我这同一个消费组两个消费者都收到了消息呢?请帮我解答下,谢谢大佬

    2年前