sarama.ConsumePartition实例是共享默认组还是使用不同的组?

huangapple go评论82阅读模式
英文:

sarama.ConsumePartition instances is sharing default group or using different group?

问题

当我在不同的进程中使用sarama.ConsumePartition来消费相同主题和相同分区时,行为是像它们共享一个默认组还是像它们使用唯一组?

英文:

When I using sarama.ConsumePartition for same topic and same partition in different process, is the behavior like they sharing an default group or like they are using unique group?

答案1

得分: 2

当你调用ConsumePartition时,你必须提供要开始消费的偏移量(以及主题和分区)。然后它将从给定的偏移量开始消费。

不会像组消费者那样共享消息/分区。

英文:

When you call ConsumePartition you HAVE to give the offset to start consuming (along with topic and partition). And it will start to consume from that given offset.

There will be no sharing of messages/partitions like group consumers.

huangapple
  • 本文由 发表于 2022年5月10日 16:59:33
  • 转载请务必保留本文链接:https://go.coder-hub.com/72183396.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定