英文:
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.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库,让每个人都能够通过互相帮助和分享经验来进步。
评论