Patent ID: 11861425
Assignee: RED HAT, INC.
Field: Computer technology (Electrical engineering)
Classification: CPC G | IPC G

Claim 16:
17. A non-transitory machine readable medium storing a program, which when executed by a processor is configured to:
send a topic discovery request to the message broker the topic discovery request requesting a list of topics registered with the message broker, wherein a topic comprises a computer message defined by the message broker;
receive, from the message broker, the list of topics registered with the message broker; determine first topic identifier data identifying a first topic of the list of topics;
determine first schema data by parsing at least one of header data or payload data of the first message, the first schema data describing first content of the first message and organization of first content of the first message;
store the first topic identifier data in association with the first schema data in a first data structure, wherein the first schema data is effective to enable a computer-implemented application to parse messages of the first topic;
receive a second message from the message broker, the second message pertaining to the first topic;
determine that the second message is associated with a same topic as the first message based on the second message being associated with the first topic identifier data;
determine that the second message comprises second schema data different from the first schema data, the second schema data describing content of the second message and organization of second content of the second message;
generate first message type data distinguishing the first message from the second message;
store the first message type data in the first data structure in association with the second schema data and the first topic identifier data;
receive a request from a first computing device, the request comprising the first topic identifier data;
determine the first schema data by performing a lookup in the first data structure using the first topic identifier data;
send the first schema data to the first computing device, wherein the first computing device develops an application programming interface (API) using the first schema data to programmatically ingest messages of the first topic.