当我在不同的进程中对相同的主题和相同的分区使用sarama.ConsumePartition时,行为是像共享默认组还是类似于使用唯一的组?
发布于 2022-06-14 11:54:39
当您调用ConsumePartition时,您必须给出开始使用的偏移量(以及主题和分区)。它将开始从给定的偏移量中消耗。
ConsumePartition
不会像组使用者一样共享消息/分区。
https://stackoverflow.com/questions/72183396
相似问题