We have a service A, which has AWS MSK event listener. It then processes the event and adds data into db. We have get API on the service, which provides the data referring to the db in step above.
We have implemented integration tests with embedded kafka and SpringBoot test. However for QA automation testing, we are figuring out how to write automated tests for invoking kafka event for end to end test. Any ideas or pointers would be helpful.