Abstract
A system for consumer-specific attribute filtering in a distributed message broker environment is provided. The system includes an attribute subscription registry configured to store a consumer identifier, a topic identifier, and a list of permitted attribute paths for each consumer. The system includes a producer interface configured to publish a canonical message payload containing a plurality of attributes to a message broker, compute an Attribute Location Index during serialization that maps each attribute name to byte offset boundaries within a serialized message body, and attach the Attribute Location Index as a message header. The system includes the message broker configured to store a single copy of the canonical message payload. The system includes a message filtering engine configured to extract permitted attributes via direct byte-offset copying using the Attribute Location Index without parsing the serialized message body and construct a filtered payload by concatenating extracted field segments. The system includes a consumer delivery layer configured to deliver the filtered payload to the requesting consumer.
Creative Commons License
This work is licensed under a Creative Commons Attribution 4.0 License.
Recommended Citation
Mishra, Soumendra Kumar; Singh, Mansi; Sinha, Ravi Shanker Kumar; Ranjan, Amitabh; Kiranmayee Kolluru, Katyayani; and Kumar, Sumit, "METHOD AND SYSTEM FOR CONSUMER-SPECIFIC ATTRIBUTE FILTERING IN DISTRIBUTED MESSAGE BROKERS", Technical Disclosure Commons, (September 16, 2026)
https://www.tdcommons.org/dpubs_series/11737