kafka定制分区器,用于跨消费者实现统一负载平衡

odopli94  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(166)

我有一个带有k个分区的主题,但是消息大小不一。假设他们的权重在1到10的范围内,消费者需要花费同等的时间/资源来处理它们。
我们如何设计一个定制的分区器来将消息分布在k个分区上,以便k个使用者具有相似的负载?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题