一种基于Kafka的消息分类和访问控制方法及系统

    公开(公告)号:CN117278378A

    公开(公告)日:2023-12-22

    申请号:CN202311226846.2

    申请日:2023-09-21

    Abstract: 本发明涉及数据处理技术领域,尤其涉及一种基于Kafka的消息分类和访问控制方法及系统,包括以下步骤:S1:定义长度描述字段和动态长度数组实现对动态长度数据的定义,即实现对语言数据结构定义;S2:对数据消息的数组长度进行二进制编码生成二进制序列,即编码消息;S3:对划分到Kafka Topic的数据类型通过二级分类方式对编码消息进行分类,产生分类消息;S4:根据选定的读取长度,对分类消息进行解码。在数据订阅消费阶段通过客户端SDK实现统一的数据访问控制,实现高性能的应用间消息通信,降低应用开发接入成本,简化升级维护管理流程,同时具备代理偏斜监控与重平衡机制,降低Kafka代理负载压力,避免潜在的性能问题,提高消息吞吐量,具备应用价值。

Patent Agency Ranking