Remove Kafka cache by handling Constraint Violation Exceptions for DataImportJournalKafkaHandler

RCA Group

None

Description

Kafka Cache is used in SRM in DataImportJournalKafkaHandler and it should be replaced by another solution for handling duplicates, it described in the diagram below.

 

Steps to be done:

  1. Use previously added tables events_processed and events_handlers from story:

  2. Populate events_handlers table with value DataImportJournalKafkaHandler after DataImportJournalVerticle starts.

  3. Modify DataImportJournalKafkaHandler to catch ConstraintViolation exception and write into log about duplicate event.

 

 

Environment

None

Potential Workaround

None

Attachments

1

Checklist

hide

TestRail: Results

Activity

Show:

Aliaksandr FedasiukJanuary 17, 2022 at 9:09 AM

Done

Done

Details

Assignee

Reporter

Priority

Story Points

Sprint

Development Team

Folijet

Fix versions

Release

Lotus R1 2022

TestRail: Cases

Open TestRail: Cases

TestRail: Runs

Open TestRail: Runs

Created December 10, 2021 at 7:02 AM
Updated March 3, 2022 at 6:44 PM
Resolved January 17, 2022 at 9:09 AM
TestRail: Cases
TestRail: Runs