1
LeeSeoung 2019-04-25 12:25:05 +08:00
kafka 的情况,一个 consumer 对应一个或者多个 partition,顺序消费,offset 递增,partition 之间互不影响。
|
2
MilesW 2019-04-25 12:29:37 +08:00
一般并发的 consumer 数不超过 patition 数,可以指定 consumer 读取哪个具体的 partition
|
3
NicolayShi OP @LeeSeoung 谢谢,某个 consumer 消费完它对应的 partition 之后会怎么样呢,
|
4
NicolayShi OP @MilesW 请问 offset 的数值是相对于 partition 还是 topic 而言的~
|
5
LeeSeoung 2019-04-25 19:15:21 +08:00
offset 相对 partition 而言,消费完 partition 后还是会根据设置定时获取。
|
6
HansCathy 2019-04-25 19:31:55 +08:00
1 个消费组包含 1 个 consumer,消费多个 partition 的情况,消费完一个 partition 会消费另一个 partition。offset 只是标记 partition 中数据顺序,不同 partition 间的 offset 没有关系。
|
7
HansCathy 2019-04-25 19:33:20 +08:00 1
@NicolayShi offset 是基于消费组+consumer+pratition 这三个唯一确定的,这也是为什么一个消费组里面多个 consumer,消费多个 partition 不存在重复消费的问题
|
8
HansCathy 2019-04-25 19:35:38 +08:00
打错了 是 topic + 消费组 + pratiton
|