#1185 - Integration Test for Kafka/ElasticSearch

[duylv27]

This PR is to add integration test for kafka, and elasticsearch (CDC Events sync data for ElasticSearch). The test will have

• Kafka:

  • One Kafka instance.
  • A manually created Product CDC topic (not the one created by the Debezium connector).
  • A Product Producer that publishes events to the CDC topic.

• Elasticsearch:

  • One Elasticsearch instance.
  • A consumer that loads data from the CDC topic.
  • The following consumer behaviors will be verified.

---

Consumer behaviors will be verified:

• Does the consumer consume events as expected? (sync by event operation)
• In case of an error, does the consumer perform a retry? (can improve more by verifying dead-letter queue topic in case retry failed).

[github-actions]

Recommendation Coverage Report

Overall Project	NaN% NaN%	🍏

There is no coverage information present for the Files changed

[github-actions]

Search Coverage Report

Overall Project	93.34% -0.64%	🍏
Files changed	89.47%	🍏

File	Coverage
ProductSyncDataConsumer.java	89.47% -10.53%	🍏

[duylv27]

Must proceed #1182 first

[sonarcloud]

Quality Gate passed for 'yas'

Issues
1 New issue
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarCloud

[sonarcloud]

Quality Gate passed for 'search'

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
67.7% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarCloud