-
Story
-
Resolution: Unresolved
-
Normal
-
None
-
None
-
5
-
False
-
-
True
-
-
As a developer,
I want translate HBI event messages into Swatch's event message schema after consuming them and produce event messages to the service-instance-ingress topic,
So that the necessary data is processed correctly and adheres to the event schema requirements.
Refer to https://docs.google.com/document/d/1Kdk0Bm8Al_1-O8oDPmvnR8SjYHZKn8J24U7SuiuDD9Y/edit from SWATCH-2850.
Acceptance Criteria:
- Message Consumption:
- The Quarkus app shouldn't just log the raw HBI ** messages anymore
- Message types (create, update, delete) are correctly identified and carried over.
- likely will need Event schema update to support this
- Message Translation:
- The HBI message is successfully translated into Swatch's event message schema.
- The appropriate service_type is assigned (HBI_HOST).
- Lookup and apply appropriate product_tag
- Kafka Producer:
- The Quarkus app successfully produces swatch Event messages to the service-instance-ingress topic when the Unleash feature flag from
SWATCH-2924is enabled.
- The Quarkus app successfully produces swatch Event messages to the service-instance-ingress topic when the Unleash feature flag from
- Message consumption
- swatch-tally consumes the message, sends it through its usual Event Ingestion pipeline, and results in an event database record being inserted
- Event Ingestion/Reconciliation should behave in its usual way (aka no regressions in current dedup logic)
- Verify hourly tally doesn't pick up these event records
- they shouldn't because the events will have a service type of HBI_HOST, and there are no swatch-product configs that match HBI_HOST
- Automated Testing
- Add component tests for new swatch-metrics-hbi
- happy path test with a life-like example of an HBI event compared with the swatch Event emitted by swatch-metric-hbi
- Functional test
- when swatch-metrics-hbi emits an Event, swatch-tally consumes it and ends up in the event table in the database
- Add component tests for new swatch-metrics-hbi
- incorporates
-
SWATCH-2876 Produce swatch Event messages to service-instance-ingress
- Closed
-
SWATCH-1993 Event ingestion for non-payg and HBI should determine product_tag
- Closed
- is blocked by
-
SWATCH-2874 Create a Quarkus app that consumes/produces Kafka messages
- Closed
- is related to
-
SWATCH-2876 Produce swatch Event messages to service-instance-ingress
- Closed