一种分布式消息系统中的数据处理方法和装置

摘要

本发明公开了一种分布式消息系统中的数据处理方法和装置，其中方法包括：为分布式消息系统中的消息主题维护用户级别的元数据；接收数据处理方对指定消息主题的用户级别的元数据读取请求，向所述数据处理方返回该指定消息主题的用户级别的元数据，以使所述数据处理方根据所述用户级别的元数据，对该指定消息主题的目标数据进行指定类型的处理。该技术方案一方面在数据层面上使得数据与其元数据在存储上的关联性更高，可以都在同一个分布式消息系统中保存，另一方面，用户可以利用用户级别的元数据保存各类信息，以应对不同的数据处理场景。