This document will illustrate how instances can be created/updated via async channels(Kafka). There are incoming use cases where Instances need to be synced with some other objects in bulk; with more guarantees than what the HTTP endpoints can provide and less coupling desired.

Event Model

The eventPayload will contain the following

Event Types

There will be two major event types

• CREATE_INSTANCE: Representing the creation of an instance.

  • if sourceRecordIdentifier is populated, the instance will be created with the same identifier.

• UPDATE_INSTANCE: Representing the update of an instance.

  • It will be required to have sourceRecordIdentifierpopulated and will be used to denote which instance to update. Value should map to a valid Inventory Instance Identifier.

  • It should not be possible to switch the source of the instance to be updated.

For the source record payload, there are some requirements

sourceType=BIBFRAME

It is expected that sourceRecordObject will be a JSON representation of a MARC file. The MARC file will be saved at mod-source-record-storage and an Instance object with source=BIBFRAME is saved at mod-inventory-storage.
source=BIBFRAME implies that the source of truth is at the Linked Data Service. In the additionalProperties object, a key-value pair will represent the identifier of the bibframe resource. The key will be bibframeId and the value with be a Long(Java)/bigint(PostgreSQL).

The source record in SRS should have the following identifiers:

• MARC

  • 999ff$i will have the Inventory instance Identifier

  • 999ff$s will have the SRS source record identifier

  • 999ff$b will have the bibframe identifier

  • 035$a will have the bibframe identifier prepended with (bibframe)

• External ID Holder will include the bibframe identifier

source=MARC To source=BIBFRAME

It will be possible that an instance with source=MARC will be converted to source=BIBFRAME but not the other way around. This will only take place when an update with a kafka message of sourceType=BIBFRAME attempts to update a source=MARC instance in Inventory.

sourceType=MARC

It is expected that sourceRecordObject will be a JSON representation of a MARC file. The MARC file will be saved at mod-source-record-storage and an Instance object with source=MARC is saved at mod-inventory-storage.

sourceType=FOLIO

It is expected that sourceRecordObject will be a JSON of an instance; same or similar the request body when creating instances via HTTP in mod-inventory. Modifications to the HTTP schema should be reflected here as well. An Instance object with source=FOLIO is saved at mod-inventory-storage.
The same code path that mutates instances via HTTP should be the same for Kafka.

Event Topic

All domain events will be pushed into a Kafka topic named inventory.instance_ingress. It will be prepended with the tenantId or topic consolidation id and also the environment. A full topic name could be folio.diku.inventory.instance_ingress .