[Search][Recommendation] Introduce Kafka Stream to aggregate all product data.

[duylv27]

Description:

The search and recommendation modules listen to the Product CDC topic (created by Debezium) to feed data into Elasticsearch and VectorDB. However, this topic only produces events when there are changes to the product table. It does not generate events when associated tables (such as category, brand, product_attribute, etc.) are updated, which can lead to incomplete or outdated data in Elasticsearch and VectorDB.

Therefore, we need to introduce Kafka Streams to aggregate event changes from all associated tables (such as category, brand, product_attribute, etc.) along with the product table.