例如,在流中,我可以有一个被分成三个部分的复合消息。换句话说,它将是Kafka流中的三个记录,但这是一个大消息。我想使用Kafka表在一个Kafka记录中合并复合消息的各个部分。合并后,将在数据库(Postgres)中插入一封邮件。每个部件都有部件数和总部件数。例如,如果我在流中有一条消息的三个部分(三个Kafka记录)-每个部分都有字段total number of part,值
select t.spdi_application_id,t.spdi_attribute_id, t.spdi_attribute_value where spdi_attribute_id in(395,263,397,396,75) ORDER BY spdi_application_id,spdi_attribute_id ERROR: column "t.spdi_attribute_