Method and system for resolving producer and consumer affinities in interaction servicing
AssigneeJPMorgan Chase Bank, N.A.
InventorsRajeshwari Edamadaka, Diarmuid Leonard
Life of this patent
Estimating the term…
Abstract
A system and a method for processing a message on a processing platform, such as a Kafka processing platform, are provided. The method includes: acquiring a plurality of partitions from the messaging platform; designating a first partition from among the plurality of partitions as a sticky partition; generating a plurality of routing keys that are configured to route messages to the sticky partition; using a first routing key from among the plurality of routing keys to identify a first service subscription; subscribing to a second service using the first routing key; and receiving a message transmitted by the second service.
Claims20
A method for processing a message on a Kafka messaging platform, the method being implemented by at least one processor, the method comprising:
- acquiring, by the at least one processor, a first plurality of subscription requests from an external facing request topic and a second plurality of subscription requests from an internal local availability zone topic;
- determining, by the at least one processor for each of the first plurality of subscription requests and for each of the second plurality of subscription requests, a respective resource-identifier;
- and
- generating, by the at least one processor for each respective resource-identifier, a corresponding subscription message.
A computing apparatus for processing a message on a Kafka messaging platform, the computing apparatus comprising:
- a processor;
- a memory;
- and
- a communication interface coupled to each of the processor and the memory,
- wherein the processor is configured to:
- acquire a first plurality of subscription requests from an external facing request topic and a second plurality of subscription requests from an internal local availability zone topic;
- determine, for each of the first plurality of subscription requests and for each of the second plurality of subscription requests, a respective resource-identifier;
- and
- generate, for each respective resource-identifier, a corresponding subscription message.
A non-transitory computer readable storage medium storing instructions for processing a message on a Kafka messaging platform, the storage medium comprising executable code which, when executed by a processor, causes the processor to:
- acquire a first plurality of subscription requests from an external facing request topic and a second plurality of subscription requests from an internal local availability zone topic;
- determine, for each of the first plurality of subscription requests and for each of the second plurality of subscription requests, a respective resource-identifier;
- and
- generate, for each respective resource-identifier, a corresponding subscription message.
Dependencies are inferred from the claim text.