Batch processing of messages
US10409658B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Jan 27, 2017 |
| Grant date | Sep 10, 2019 |
| Priority date | — |
| Expiry date | Oct 2, 2037 |
Classification
- Technology area (CPC G)Physics
- CPC primaryG06F9/546
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
A method and associated system. For each message of a message batch, the message is assigned by a consumer to a partition of a log. Each partition of the log is associated with a respective processing engine. The message batch includes messages that includes the message. The consumer stores an offset value for each partition. Responsive to completion, by a distributor, of sending a last message in the message batch to the consumer, the distributor ascertains a target offset value for each partition based on a current offset value. In response to a processing engine completing processing of a message assigned to the partition associated with the processing engine, the consumer updates the stored offset value associated with the partition. The distributor determines when all messages of the batch have been processed based on the target offset values and the stored offset values.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.