Multiple contributions are going to use MQueues, so it makes senses to ease the MQManager access and configuration.
The goal is to provide a service that:
- Register MQManager configuration:
- A name, that will be used to request a MQManager
- Type of MQueue: Kafka or Chronicle
- Options: point to kafka configuration or define Chronicle base path and retention
- Initialize MQueue on startup: So that producers code don't have to check and create MQueue on startup, also this makes the number of partitions configurable
- Start consumers by contributing a computation topology: the EP will take a class that can return a Topology, the setttings will be part of the EP.
- is required by
-
NXP-22109 Provides an Audit writer impl with Computation
- Resolved