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

Claim 0:
1. A method comprising:
sending, by at least one processor, a topic discovery request to a message broker of an asynchronous computer messaging architecture, 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;
receiving, by the at least one processor from the message broker, the list of topics registered with the message broker; determining, by the at least one processor, first topic identifier data identifying a first topic of the list of topics;
receiving, by the at least one processor, a first message from the message broker, the first message pertaining to the first topic;
determining, by the at least one processor, first schema data by parsing at least one of first header data or first payload data of the first message, the first schema data describing first content of the first message and organization of the first content of the first message;
generating, by the at least one processor, a first mapping between the first topic identifier data and the first schema data by storing 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;
receiving a second message from the message broker, the second message pertaining to the first topic; determining 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;
determining 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 the content of the second message;
generating first message type data distinguishing the first message from the second message;
storing the first message type data in the first data structure in association with the second schema data and the first topic identifier data; receiving a request from a first computing device, the request comprising the first topic identifier data; determining the first schema data by performing a lookup in the first data structure using the first topic identifier data; sending 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.