赞
踩
Case:前端采集的数据通过Kafka Topic回传至后端分析程序,但是单个分析线程(Consumer)很有可能忙不过来。
既然单个消费者忙不过来,那就多来几个消费者。此时,这些消费者就构成了一个小团队。
Topic中的消息在被分割、摊派后,每个成员(消费者)就自顾自地忙自己那部分。
在Kafka中,这个团队称为”Consumer Group”。
至于同一个Topic中的Message如何摊派呢?
一个Partition给一个消费者。 一对一的形式,易于Partition offset的管理。
当然,Consumer可以同时处理多个Partition。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。