DI - Setting up support for multi partition and Kafka concurrency

[ndduc01]

Notes

Please include a summary of the change and which issue is fixed or which feature is added.

JIRA

• Related story: Jira Ticket

Checklist

• PR focuses on a single story.
• New unit tests added and ensured they pass.
• Service has been tested in local and it works as expected.
• Documentation has been updated for this code change (if needed).
• Code follows the Java Coding Conventions (https://www.oracle.com/java/technologies/javase/codeconventions-programmingpractices.html).

Types of changes

What types of changes does this PR introduces?

• Bugfix
• New feature
• Breaking change

Testing

• Does this PR has >90% code coverage?
• Is the screenshot attached for code coverage?
• Does the gradle build pass in your local?
• Is the gradle build logs attached?

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

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

See analysis details on SonarQube Cloud