Details
-
Story
-
Status: Closed (View Workflow)
-
P3
-
Resolution: Done
-
None
-
-
Falcon Sprint 104
-
8
-
Falcon
Description
Overview:
Apache Kafka should be used directly in inventory-storage for implementation of domain event pattern, which is needed for both remote-storage integration and new search module. This direct usage of Apache Kafka should be considered as a special case, as it was for data-import. Also it is special case, that storage module use more than one data storage. However, Kafka is used here not for data storage, but for event provision for interaction between modules.
(see: https://wiki.folio.org/display/DD/Apache+Kafka+usage+in+inventory-storage)
Requirements/Scope:
- On every create message should be sent with id of the created entity as the partition key and body, which contains update action name ("CREATE") in message header and entity in "new"
- On every update the similar message should be sent but with action name ("UPDATE") and "old" and "new" state of the entity (see below)
- On every detele the similar message should be sent but with action name ("DELETE") and with json of entity, that was deleted in "old" and empty "new"
Technical details:
The Kafka integration should be done according to POC, which is made by Taras_Spashchenko.
The name of the topic should be inventory.entity_type .
JSON structure:
{
"old" :
,
"new" :
"type" : "UPDATE"
}
NB: for each item instnace id should be sent, whih is taken from the corresponding holding (retriving of the holding has been already in place)
TestRail: Results
Attachments
Issue Links
- defines
-
UXPROD-2696 Remote Storage Integration (Dematic thin thread)
-
- Closed
-
-
UXPROD-2807 Create FOLIO internal Elasticsearch APIs
-
- Closed
-
- is blocked by
-
FOLIO-2915 Set kafka host and port for mod-inventory-storage in rancher
-
- Closed
-
- is cloned by
-
MODINVSTOR-639 Domain events sending in inventory-storage for item
-
- Closed
-
-
MODINVSTOR-640 Domain events sending in inventory-storage for holdings-record
-
- Closed
-
-
MODINVSTOR-644 Domain events sending in inventory-storage for instance [batch APIs]
-
- Closed
-
- relates to
-
FOLIO-2905 Set kafka host and port for mod-inventory-storage
-
- Closed
-
-
FOLIO-2909 SPIKE: checkout-by-barcode receives 500 but loan is created
-
- Closed
-