Patent №
US 10,409,658
Granted
2019-09-10
Filed 2017
Owner
INTERNATIONAL BUSINESS MACHINES CORPORATION
Lab
AI components
2
kr · hardware
Assignment
Recorded
Dataset
AIPD
2023_r1 edition
Application
15417418
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.
AI classification
Ownership
INTERNATIONAL BUSINESS MACHINES CORPORATION
assignment · 411000974
Assignors
BROADHURST, PETER A., HOSIE, JOHN, NICHOLSON, ROBERT B., PHIPPEN, ROBERT W.
On an employer assignment, the assignors are typically the inventors.