请描述您的问题
标题:年底大酬宾-腾讯云
地址:https://cloud.tencent.com/act/bargin?fromSource=gwzcw.634234.634234.634234
浏览器信息
Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36
请描述您的问题
标题:年底大酬宾-腾讯云
地址:https://cloud.tencent.com/act/bargin?utm_source=portal&utm_medium=banner&utm_campaign=bargin&utm_term=1204
浏览器信息
Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_2) AppleWebKit/604.4.7 (KHTML, like Gecko) Version/11.0.2 Safari/604.4.7
请描述您的问题
标题:腾讯云云产品新购特惠,五折上云!
地址:https://cloud.tencent.com/act/first_purchase?utm_source=portal&utm_medium=cdb&utm_campaign=firstpurchase&utm_term=0110
浏览器信息
Mozilla/5.0 (Macintosh; Intel Mac OS X 10.13; rv:58.0) Gecko/20100101 Firefox/58.0
请描述您的问题
标题:腾讯云云产品新购特惠,五折上云!
地址:https://cloud.tencent.com/act/first_purchase?utm_source=portal&utm_medium=cdb&utm_campaign=firstpurchase&utm_term=0110
浏览器信息
Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36
我使用Kafka来处理消息。消息可以分成几个部分(它是一个复合消息)。例如,在流中,我可以有一个被分成三个部分的复合消息。换句话说,它将是Kafka流中的三个记录,但这是一个大消息。我想使用Kafka表在一个Kafka记录中合并复合消息的各个部分。合并后,将在数据库(Postgres)中插入一封邮件。每个部件都有部件数和总部件数。例如,如果我在流中有一条消息的三个部分(三个Kafka记录)-每个部分都有字段total number of part,值为3。
我的理解是,任务在积极的场景中很简单:在表中聚合部件,从表中创建流,并过滤具有等于聚合部件大小和部件总数的记录,映射在一个合并的消息中过滤