The patent badge is an abbreviated version of the USPTO patent document. The patent badge does contain a link to the full patent document.

The patent badge is an abbreviated version of the USPTO patent document. The patent badge covers the following: Patent number, Date patent was issued, Date patent was filed, Title of the patent, Applicant, Inventor, Assignee, Attorney firm, Primary examiner, Assistant examiner, CPCs, and Abstract. The patent badge does contain a link to the full patent document (in Adobe Acrobat format, aka pdf). To download or print any patent click here.

Date of Patent:
Sep. 29, 2026

Filed:

Aug. 26, 2024
Applicant:

Oracle International Corporation, Redwood Shores, CA (US);

Inventors:

Rajasekaran Iyanu, Bengaluru, IN;

Kirk Bittler, Newport, OR (US);

Shengsong Ni, Issaquah, WA (US);

Assignee:

ORACLE INTERNATIONAL CORPORATION, Redwood Shores, CA (US);

Attorney:
Primary Examiner:
Assistant Examiner:
Int. Cl.
CPC ...
G06F 11/00 (2006.01); G06F 11/07 (2006.01);
U.S. Cl.
CPC ...
G06F 11/0757 (2013.01);
Abstract

In accordance with an embodiment, described herein are a system and method for use with a distributed event streaming environment (e.g., a Kafka environment), for making services resilient of producer failures. When a determination is made that one or more messages could not be sent to a particular topic after a timeout error, those messages are stored in a centralized cache (e.g., as provided by a database service). A key-partitioner algorithm or process is used to pre-compute a partition ID into which the message will be re-sent. The pre-computed partition ID is used to compute the key of the cache entry for the message as stored within the centralized cache. A recurrent watchdog per group of microservice resources (e.g., per pod) operates to query the centralized cache for the messages to be re-sent into the partitions pertaining to those resources (i.e., that pod).


Find Patent Forward Citations

Loading…