因为 kafka 的设计,一个分区只能被一个消费者消费。 日常,可能因为高峰期,为了增加处理能力,增加服务实例,但 kafka 的分区并不容易增加减少。 如果增加了服务实例,新增的实例就没得消费。
因为 kafka 的设计,一个分区只能被一个消费者消费。 日常,可能因为高峰期,为了增加处理能力,增加服务实例,但 kafka 的分区并不容易增加减少。 如果增加了服务实例,新增的实例就没得消费。
|
BadlinkMar 4, 2023
1
消费后多线程处理,或者如果消费后处理过程可以拆分的话,也可以用多个消费组进行消费,再分别处理不同任务吧
|
|
rrfengMar 4, 2023 via Android
2
不能,其实加分区还是很容易的,减分区不容易。
|
|
securityCodingMar 4, 2023 via Android
3
怎么不能调整呢
|
|
hyperdak288Mar 4, 2023
4
基于 kafka 架构的问题,调整分区是比较痛苦的事。
pulsar 可以比较好解决好问题,分区的调整成本非常低。 |
|
julyclydeMar 6, 2023
5
你这个问法错误
应该问“怎么解决 kafka 消费者不能增加的问题” |