neyzoter.

0 声望

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

个人动态
  • 半兽人 回复 neyzoter.kafka入门介绍 中 :

    nice,ღ( ´・ᴗ・` )。

    1年前
  • 赞了 半兽人kafka生产者Java客户端 的评论!

    发送消息缓存有2个条件,满足指定大小,立即发送,到达指定的时间,即使消息大小不满足,也立即发送。

    1年前
  • 赞了 無名kafka生产者Java客户端 的评论!

    不影响的,如果你异步发送,阻塞也是异步阻塞的,不会涉及到主线程的。并且是当ack=all的时候,才会异步阻塞。

    1年前
  • 赞了 半兽人kafka生产者Java客户端 的评论!

    消息已经到了集群,并且已经落地。(不会丢了)

    1年前
  • neyzoter. 回复 半兽人kafka入门介绍 中 :

    嗯嗯。
    感觉第2点说的不是特别准确。如果生产者根据自定义的Partitioner只往一个partition中发数据,那么就算是一个消费者组内是2个同名消费者也是只有一个可以接收到这个partition的数据。

    1年前
  • 半兽人 回复 neyzoter.kafka入门介绍 中 :

    1、生产者和消费者没有任何关系,生产者生产出来的数据到topic,谁消费已经跟它无关了。
    2、比如一个topic有2个partition,2个partition有10条消息,消费者组A有2个消费者,那它们俩来平分消息,一人5条,B组也会收到这10条,跟A组一样,所以,总结下来,不同的组同事拿到10条,组内的成员,平分消息。

    1年前
  • neyzoter. 回复 半兽人kafka入门介绍 中 :

    感谢回复!那您所说的队列其实是通过生产者随机分发数据到不同的partition,然后将所有的消费者放到一个消费者组中来实现的?那不是不需要同名也是可以的?

    1年前
  • 半兽人 回复 neyzoter.kafka入门介绍 中 :

    说明一个topic里,分区只有一个,那消费组中2个只能有1个消费在消费。

    1年前
  • 赞了 半兽人kafka入门介绍 的评论!

    如果只有2个broker,如果你建10个分区,那都会在这2个broker上了。

    1年前
  • 赞了 半兽人kafka入门介绍 的评论!

    这个offset只跟消费者组有关,按照你的例子来。消费者组中有a,b,c三个消费者。
    当它们同时运行之后,a消费A,b消费B,c消费C。总共维护3个offset你的理解是对的。
    这个时候,如果a消费者挂掉,kafka会进行消息平衡,将之前a消费者的A分区,分配给了b消费者。
    这时消费者b就会接着消费A分区。这时b就同时消费A和B了,c还是只消费C。

    1年前
  • 订阅了 kafka 主题! · 1年前